Check the number of partitions of a specific topic with the following command:
./bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic event
and change the number of partitions of the topic with the following command:
./bin/kafka-topics.sh --zookeeper localhost:2181 --topic event --alter --partitions 10
No comments:
Post a Comment