标签:creat img list from OLE mamicode ica partition kafka
接上一篇kafka环境搭建完成后,进入测试阶段,首先试一下最基本的生产与消费者。
1、创建topic,使用 kafka-topics.sh 创建 topic test
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
2、创建消息生产者
看一下zookeeper 配置信息: bin/zookeeper-shell.sh localhost:2181 <<< "get /brokers/ids/0"
创建时生产者的时候我们用的是**localhost,**这里我们改成:bin/kafka-console-producer.sh --broker-list PLAINTEXT://上面的ip:9092 --topic test
3、创建消息消费者;bin/kafka-console-consumer.sh --bootstrap-server PLAINTEXT://上面的ip:9092 --topic test --from-beginning
在生产消息的窗口输入内容,消费窗口就可以打印出来:
标签:creat img list from OLE mamicode ica partition kafka
原文地址:https://www.cnblogs.com/bigmengzilogs/p/12699663.html