常用命令

Topic 列表

kafka-topics.sh --list --zookeeper 172.16.254.28:2181

Topic 创建

kafka-topics.sh --create --zookeeper 172.16.254.28:2181 --replication-factor 1 --partitions 1 --topic test

Producer 生产

kafka-console-producer.sh --broker-list 172.16.254.28:9092 --topic test 

Consumer 消费

//从头消费
kafka-console-consumer.sh --bootstrap-server 172.16.254.28:9092 --topic test --from-beginning