常用命令
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
网友评论