一、创建topic:
kafka-topics.sh --create --replication-factor 1 --partitions 3 --zookeeper localhost:2181 --topic wklc-nginx-weixin
二、查看topic list:
kafka-topics.sh --zookeeper 127.0.0.1 --list
三、查看单个topic:
kafka-topics.sh --zookeeper 127.0.0.1 --topic api3-nginx --describe
四、从console消费:
kafka-console-consumer.sh --topic wklc-nginx --zookeeper 127.0.0.1:2181 --from-beginning
五、
继续阅读与本文标签相同的文章
上一篇 :
elasticsearch 优化
下一篇 :
Gitlab部署文档
-
虚方法和多态
2026-05-17栏目: 教程
-
走进JavaWeb技术世界14:Mybatis入门
2026-05-17栏目: 教程
-
深入JavaWeb技术世界15:深入浅出Mybatis基本原理
2026-05-17栏目: 教程
-
阿里云双十一活动新鲜出炉!第一重·亿元双十一补贴提前领!!!
2026-05-17栏目: 教程
-
Android APT 实例讲解
2026-05-17栏目: 教程
