Commit 49c64ffa authored by Lionel Walter's avatar Lionel Walter
Browse files

Use only one kafka partition

parent 9c4d8391
Pipeline #10137 passed with stages
in 8 minutes and 38 seconds
......@@ -90,7 +90,8 @@ class KafkaTopics(Resource):
new_topic_list = []
for topic in topics:
new_topic_list.append(NewTopic(name=topic, num_partitions=3, replication_factor=1))
# todo use multiple partitions
new_topic_list.append(NewTopic(name=topic, num_partitions=1, replication_factor=1))
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment