Skip to content

Commit 09ea1e2

Browse files
Update docs to mention auto.offset.reset is now latest by default in Kafka configs
1 parent dffd264 commit 09ea1e2

1 file changed

Lines changed: 4 additions & 5 deletions

File tree

streamz/sources.py

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -624,13 +624,12 @@ def from_kafka_batched(topic, consumer_params, poll_interval='1s',
624624
625625
| More information at: https://rapids.ai/start.html
626626
627-
628627
Important Kafka Configurations
629628
----------
630-
If 'auto.offset.reset': 'latest' is set in the consumer configs,
631-
the stream starts reading messages from the latest offset. Else,
632-
if it's set to 'earliest', it will read from the start offset.
633-
629+
By default, a stream will start reading from the latest offsets
630+
available. Please set 'auto.offset.reset': 'earliest' in the
631+
consumer configs, if the stream needs to start processing from
632+
the earliest offsets.
634633
635634
Examples
636635
----------

0 commit comments

Comments
 (0)