一、创建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
五、

收藏 打印