Skip to content

Commit 2a2983f

Browse files
peterklipfelJoshRosen
authored andcommitted
fixed spelling errors in documentation
changed "form" to "from" in 3 documentation entries for Kafka integration Author: Peter Klipfel <[email protected]> Closes #3691 from peterklipfel/master and squashes the following commits: 0fe7fc5 [Peter Klipfel] fixed spelling errors in documentation
1 parent ef84dab commit 2a2983f

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ object KafkaUtils {
7575
}
7676

7777
/**
78-
* Create an input stream that pulls messages form a Kafka Broker.
78+
* Create an input stream that pulls messages from a Kafka Broker.
7979
* Storage level of the data will be the default StorageLevel.MEMORY_AND_DISK_SER_2.
8080
* @param jssc JavaStreamingContext object
8181
* @param zkQuorum Zookeeper quorum (hostname:port,hostname:port,..)
@@ -93,7 +93,7 @@ object KafkaUtils {
9393
}
9494

9595
/**
96-
* Create an input stream that pulls messages form a Kafka Broker.
96+
* Create an input stream that pulls messages from a Kafka Broker.
9797
* @param jssc JavaStreamingContext object
9898
* @param zkQuorum Zookeeper quorum (hostname:port,hostname:port,..).
9999
* @param groupId The group id for this consumer.
@@ -113,7 +113,7 @@ object KafkaUtils {
113113
}
114114

115115
/**
116-
* Create an input stream that pulls messages form a Kafka Broker.
116+
* Create an input stream that pulls messages from a Kafka Broker.
117117
* @param jssc JavaStreamingContext object
118118
* @param keyTypeClass Key type of RDD
119119
* @param valueTypeClass value type of RDD

0 commit comments

Comments
 (0)