kafka 运维相关

查看当前 topic 列表

./bin/kafka-topics.sh --bootstrap-server localhost:9092 --list

手动创建 topic

./bin/kafka-topics.sh \
  --bootstrap-server localhost:9092 \
  --create \
  --topic test-topic \
  --partitions 3 \
  --replication-factor 1

验证 topic 是否真的存在

./bin/kafka-topics.sh  --bootstrap-server localhost:9092 --describe --topic test-topic

Partition 数量怎么定？

partition ≈ max(消费者并发数, 写入并发数 / 2)

分区数宁多勿少