卡夫卡主题

此工具允许你列出,创建,更改和描述主题。

列出主题:

kafka-topics  --zookeeper localhost:2181 --list

创建一个主题:

kafka-topics  --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

使用一个分区创建主题,不进行复制。

描述一个主题:

kafka-topics  --zookeeper localhost:2181 --describe --topic test

改变话题:

# change configuration
kafka-topics  --zookeeper localhost:2181 --alter --topic test --config max.message.bytes=128000
# add a partition
kafka-topics  --zookeeper localhost:2181 --alter --topic test --partitions 2

(注意:Kafka 不支持减少主题的分区数量)(请参阅此配置属性列表