diff --git a/python_examples/producer.py b/python_examples/producer.py index fe412c5..b53b650 100644 --- a/python_examples/producer.py +++ b/python_examples/producer.py @@ -27,7 +27,7 @@ def init_system(client: IggyClient): client.create_topic( stream_id=STREAM_NAME, # Assuming a method exists to create a numeric Identifier. partitions_count=1, - name=STREAM_NAME, + name=TOPIC_NAME, compression_algorithm="none", ) print("Topic was created.")