Kafka topic 记录

1、创建 topic

./kafka-topics.sh --create --zookeeper ip:port --replication-factor 1 --partitions 2 --topic my-topic

其中--replication-factor 配置副本数，--partitions 配置分区数

2、查看 topic 详细信息

./kafka-topics.sh --describe --zookeeper ip:port --topic my-topic

3、列出所有 topic

./kafka-topics.sh --list --zookeeper ip:port

4、删除 topic

./kafka-topics.sh --delete --zookeeper ip:port --topic my-topic

5、修改 topic 保存消息的时长

./kafka-configs.sh --zookeeper ip:port --alter --entity-type topics --entity-name  my-topic --add-config retention.ms=172800000

retention.ms=172800000 配置为保留2天

6、增加 topic partitions 数

./kafka-topics.sh --alter --zookeeper ip:port  --topic my-topic --partitions 3

扩展分区数，只能增加，不能减少。如果要减少分区数，只能删掉原来的 topic 然后重建。

本文由 Chakhsu Lau 创作，采用 知识共享署名4.0 国际许可协议进行许可。
本站文章除注明转载/出处外，均为本站原创或翻译，转载前请务必署名。