Skip to content

Commit 2d2a3b8

Browse files
committed
chore: user 10 partions for Kafka events locally
1 parent 47d188e commit 2d2a3b8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

local/kafka-client/create-topics.sh

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,5 +2,5 @@
22

33
/opt/kafka/bin/kafka-topics.sh --list --zookeeper zookeeper:2181 > exists-topics.txt
44
while read topic; do
5-
/opt/kafka/bin/kafka-topics.sh --create --if-not-exists --zookeeper zookeeper:2181 --partitions 1 --replication-factor 1 --topic $topic
5+
/opt/kafka/bin/kafka-topics.sh --create --if-not-exists --zookeeper zookeeper:2181 --partitions 10 --replication-factor 1 --topic $topic
66
done < <(sort topics.txt exists-topics.txt exists-topics.txt | uniq -u)

0 commit comments

Comments
 (0)