kafka在创建topic出现zookeeper is not a recognized option

阅读: 评论:0

kafka在创建topic出现zookeeper is not a recognized option

kafka在创建topic出现zookeeper is not a recognized option

自己搭建个zookeeper和kafka记录一下错误。

在网上找了好久,终于看到了错误原因。

新版本的kafka,已经不需要依赖zookeeper来创建topic,新版的kafka创建topic指令为下:

./kafka-topics.sh --create --bootstrap-server localhost:9097 --replication-factor 1 --partitions 1 --topic test1

发送:

 ./kafka-console-producer.sh --broker-list localhost:9097 --topic test

>hello

>world

接受:

./kafka-console-consumer.sh --bootstrap-server slave1:9097 --topic test --from-beginning hello word

hello

world

本文发布于:2024-02-05 04:21:16,感谢您对本站的认可!

本文链接:https://www.4u4v.net/it/170723993762989.html

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。

标签:topic   kafka   zookeeper   option   recognized
留言与评论(共有 0 条评论)
   
验证码:

Copyright ©2019-2022 Comsenz Inc.Powered by ©

网站地图1 网站地图2 网站地图3 网站地图4 网站地图5 网站地图6 网站地图7 网站地图8 网站地图9 网站地图10 网站地图11 网站地图12 网站地图13 网站地图14 网站地图15 网站地图16 网站地图17 网站地图18 网站地图19 网站地图20 网站地图21 网站地图22/a> 网站地图23