From 466560db74fd240c253c12c2590ce30edf422713 Mon Sep 17 00:00:00 2001
From: Raghu Angadi <rangadi@google.com>
Date: Tue, 7 Jun 2016 09:55:34 -0700
Subject: [PATCH 1/2] a small update to KafkaIO javadoc

---
 .../src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java  | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java
index 9645d7c20083..2135d59881a0 100644
--- a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java
+++ b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java
@@ -167,9 +167,8 @@
  *
  * <pre>{@code
  *
- *  pipeline
- *    .apply(...) // returns PCollection<KV<Long, String>>
- *    .apply(KafkaIO.write()
+ *  PCollection<KV<Long, String>> kvColl = ...
+ *  kvColl.apply(KafkaIO.write()
  *       .withBootstrapServers("broker_1:9092,broker_2:9092")
  *       .withTopic("results")
  *

From 2e34711858f3eb1245d0909697efe6dac41aa336 Mon Sep 17 00:00:00 2001
From: Raghu Angadi <rangadi@google.com>
Date: Tue, 7 Jun 2016 10:00:38 -0700
Subject: [PATCH 2/2] ;

---
 .../src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java
index 2135d59881a0..d540a8df1518 100644
--- a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java
+++ b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java
@@ -167,7 +167,7 @@
  *
  * <pre>{@code
  *
- *  PCollection<KV<Long, String>> kvColl = ...
+ *  PCollection<KV<Long, String>> kvColl = ...;
  *  kvColl.apply(KafkaIO.write()
  *       .withBootstrapServers("broker_1:9092,broker_2:9092")
  *       .withTopic("results")