Skip to content
Snippets Groups Projects
Commit 95b3cf12 authored by microwishing's avatar microwishing Committed by Sean Owen
Browse files

[DOCUMENTATION][KAFKA] fix typo in kafka/OffsetRange.scala

this is to fix some typo in external/kafka/src/main/scala/org/apache/spark/streaming/kafka/OffsetRange.scala

Author: microwishing <wei.zhu@kaiyuandao.com>

Closes #10121 from microwishing/master.
parent 7470d9ed
No related branches found
No related tags found
No related merge requests found
......@@ -151,7 +151,7 @@ private[kafka] class KafkaTestUtils extends Logging {
}
}
/** Create a Kafka topic and wait until it propagated to the whole cluster */
/** Create a Kafka topic and wait until it is propagated to the whole cluster */
def createTopic(topic: String): Unit = {
AdminUtils.createTopic(zkClient, topic, 1, 1)
// wait until metadata is propagated
......
......@@ -20,7 +20,7 @@ package org.apache.spark.streaming.kafka
import kafka.common.TopicAndPartition
/**
* Represents any object that has a collection of [[OffsetRange]]s. This can be used access the
* Represents any object that has a collection of [[OffsetRange]]s. This can be used to access the
* offset ranges in RDDs generated by the direct Kafka DStream (see
* [[KafkaUtils.createDirectStream()]]).
* {{{
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment