卡夫卡主題

此工具允許你列出,建立,更改和描述主題。

列出主題:

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 不支援減少主題的分割槽數量)(請參閱此配置屬性列表