1、创建主题
1 | ./kafka-topics.sh --create --zookeeper 133.0.120.193:2181 --replication-factor 1 --partitions 2 --topic 主题名 |
2、列出所有主题
1 | ./kafka-topics.sh --list --zookeeper 192.168.1.200:2181 |
3、查看主题
1 | ./kafka-topics.sh --describe --zookeeper 192.168.1.200:2181 --topic 主题名 |
4、增加主题分区
1 | ./kafka-topics.sh --zookeeper 192.168.1.200:2181 --alter --topic 主题名 --partitions 5 |
5、查看主题指定分区 offset 的最大值或最小值。time 为 -1 时表示最大值，为 -2 时表示最小值：
1 | ./kafka-run-class.sh kafka.tools.GetOffsetShell --topic 主题名 --time -1 --broker-list 192.168.1.200:9092 --partitions 0 |
6、删除主题
1 | ./kafka-topics.sh --zookeeper 192.168.1.200:2181 --topic 主题名 --delete |
7、控制台生产消息
1 | ./kafka-console-producer.sh --broker-list 192.168.1.200:9092 --topic 主题名 |
8、控制台消费消息
1 | ./kafka-console-consumer.sh --bootstrap-server 192.168.1.200:9092 --topic 主题名 --from-beginning |
