标签:keep 发送 list ref put pre out output ica
1、创建主题
./kafka-topics.sh --create --zookeeper vm1:2181,vm2:2181,vm3:2181 --replication-factor 1 --partitions 1 --topic streams-plaintext-input
2、查看主题
./kafka-topics.sh --describe --zookeeper vm1:2181,vm2:2181,vm3:2181 --topic streams-plaintext-input
3、发送消息
./kafka-console-producer.sh --broker-list vm1:9092,vm2:9092,vm3:9092 --topic streams-plaintext-input
4、消费消息
./kafka-console-consumer.sh --bootstrap-server vm1:9092,vm2:9092,vm3:9092 --from-beginning --topic streams-pipe-output
具体参数不明白 ,--help
参考:https://www.cnblogs.com/cjsblog/p/9409443.html
标签:keep 发送 list ref put pre out output ica
原文地址:https://www.cnblogs.com/mylittlecabin/p/11503676.html