Kafka高低版本基本操作差异分析

原创
04/28 16:32
阅读数 45

1.低版本的kafka
启动kafka

sh kafka-server-start.sh -daemon ../config/server.properties

topics列表
sh kafka-topics.sh --zookeeper 172.16.44.10:2191 --list

创建topic
sh kafka-topics.sh --zookeeper 172.16.44.10:2191 --create --topic topic123 --partitions 1 --replication-factor 1 

topic生产数据
sh kafka-console-producer.sh --broker-list 172.16.44.10:9092 --topic topic123

消费topic

sh kafka-console-consumer.sh --bootstrap-server 172.16.44.10:9092 --topic topic123 --from-beginning

 

2.高版本的kafka
------------------------------------------------------------------

消费者
sh kafka-console-consumer.sh --bootstrap-server 172.16.9.166:9092 --zookeeper 172.16.9.166:2181 --topic topic456 --from-beginning

生产者
sh kafka-console-producer.sh --broker-list 172.16.9.166:9092 --topic topic456


sh kafka-topics.sh --zookeeper 172.16.44.8:9500 --list

sh kafka-console-consumer.sh --bootstrap-server 172.16.44.8:9600 --topic topic_yuming --from-beginning

sh kafka-console-producer.sh --broker-list 172.16.44.8:9600  --topic topic_yuming

展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部