一、主题
- 创建
./bin/kafka-topics.sh --create --zookeeper 192.168.8.9:2181 --replication-factor 1 --partitions 1 --topic test
- 列表
./bin/kafka-topics.sh --list --zookeeper 192.168.8.9:2181
- 删除
./bin/kafka-topics.sh --delete --zookeeper 192.168.8.9:2181 --topic test
如果设置delete.topic.enable=true
1.先停止kafka并进入zk shell
./bin/zkCli.sh -server localhost:2181
2.分别执行以下命令
ls /brokers/topics
rmr /brokers/topics/erplog
ls /admin/delete_topics
3.重启zk并启动kafka
- 详情
./bin/kafka-topics.sh --describe --zookeeper 192.168.8.9:2181 --topic test
二、发送消息
- 创建
./bin/kafka-console-producer.sh --broker-list 192.168.8.10:9092 --topic test
三、消费消息
- 创建
./bin/kafka-console-consumer.sh --bootstrap-server 192.168.8.10:9092 --topic test --from-beginning
四、消费组
- 列表
./bin/kafka-consumer-groups.sh --bootstrap-server 192.168.8.10:9092 --list
- 详情
./bin/kafka-consumer-groups.sh --bootstrap-server 192.168.8.10:9092 --describe --group groupname文章来源：https://www.toymoban.com/news/detail-513842.html
- 删除
./bin/kafka-consumer-groups.sh --bootstrap-server 192.168.8.10:9092 --delete --group groupname文章来源地址https://www.toymoban.com/news/detail-513842.html
到了这里，关于Kafka常用操作命令的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
