We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8ec62b8 commit b3845b3Copy full SHA for b3845b3
examples/streams/example_with_streams.py
@@ -104,7 +104,9 @@ def main() -> None:
104
message_handler=MyMessageHandler(),
105
# can be first, last, next or an offset long
106
# you can also specify stream filters with methods: apply_filters and filter_match_unfiltered
107
- stream_consumer_options=StreamConsumerOptions(offset_specification=OffsetSpecification.first),
+ stream_consumer_options=StreamConsumerOptions(
108
+ offset_specification=OffsetSpecification.first
109
+ ),
110
)
111
print(
112
"create a consumer and consume the test message - press control + c to terminate to consume"
0 commit comments