kafka 脚本 创建 topic producer consumer demo

数据流通道

2018-08-09

33

0

技术:kafka

运行环境:kafka

demo功能:提供一个脚本创建topic, 生产消息, 消费消息的demo

创建topic

./kafka-topics.sh --zookeeper 127.0.0.1:2181/kafka --replication-factor 1 --partitions 5 --topic topic2018080301francis --create

创建生产者, 输入消息

./kafka-console-producer.sh --broker-list localhost:9092 --topic topic2018080301francis

启动消费者,消费消息

./kafka-console-consumer.sh --zookeeper 127.0.0.1:2181/kafka --topic topic2018080301francis --from-beginning
 
 

欢迎添加微信,互相学习↑↑↑ -_-

发表评论

全部评论:0条

白老虎

programming is not only to solve problems, ways to think