Doc changes

apache · Nov 11, 2014 · 4a1c3f9 · 4a1c3f9
1 parent b2c1430
commit 4a1c3f9
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala
@@ -158,8 +158,8 @@ object KafkaUtils {
    * When 'auto.offset.reset' = 'largest', directly read data from end, ignore old, unwanted data.
    * This is default in Kafka 0.8.
    *
-   * To avoid concurrent deleting Zookeeper metadata in each Receiver when multiple consumers are
-   * launched, this should be call be createStream().
+   * To avoid deleting existing Zookeeper metadata in each Receiver when multiple consumers are
+   * launched, this should be called be createStream().
    * @param zkQuorum Zookeeper quorum (hostname:port,hostname:port,..).
    * @param groupId The group id for this consumer.
    */