Skip to content

Commit 65e5c2c

Browse files
committed
formatting
Signed-off-by: Gabriele Santomaggio <[email protected]>
1 parent 853e20e commit 65e5c2c

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

examples/streams/example_with_streams.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,9 @@ def main() -> None:
104104
message_handler=MyMessageHandler(),
105105
# can be first, last, next or an offset long
106106
# you can also specify stream filters with methods: apply_filters and filter_match_unfiltered
107-
stream_consumer_options=StreamConsumerOptions(offset_specification=OffsetSpecification.first),
107+
stream_consumer_options=StreamConsumerOptions(
108+
offset_specification=OffsetSpecification.first
109+
),
108110
)
109111
print(
110112
"create a consumer and consume the test message - press control + c to terminate to consume"

0 commit comments

Comments
 (0)