Kafka topic 配置使用记录
in Note with 0 comment
Kafka topic 配置使用记录
in Note with 0 comment

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 然后重建。

Responses