Github user HyukjinKwon commented on a diff in the pull request:
    --- Diff: python/pyspark/streaming/ ---
    @@ -104,7 +104,7 @@ def createDirectStream(ssc, topics, kafkaParams, 
             :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 --
    Shall we fix as so?


To unsubscribe, e-mail:
For additional commands, e-mail:

Reply via email to