Github user aviv-ebates commented on a diff in the pull request:
https://github.com/apache/spark/pull/21057#discussion_r181460539
--- 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 --
Yeah, that works too.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
