Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/21057#discussion_r181299329
--- Diff: python/pyspark/streaming/kafka.py ---
@@ -104,7 +104,7 @@ def createDirectStream(ssc, topics, kafkaParams,
fromOffsets=None,
:param topics: list of topic_name to consume.
:param kafkaParams: Additional params for Kafka.
:param fromOffsets: Per-topic/partition Kafka offsets defining the
(inclusive) starting
- point of the stream.
+ point of the stream (Dict with keys of type
TopicAndPartition and int values).
--- End diff --
I would say sth like ``a dictionary containing `TopicAndPartition` to
integers.``.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
