赞
踩
使用版本及配置:
Zookeeper:3.8.2,默认端口2181。
Kafka:2.12-3.5.1,默认端口9092,配置文件中修改了log.dirs和listeners的ip改成了本虚拟机的ip(其实不修改listeners的话默认也是这个localhost ip)listeners=PLAINTEXT://192.168.154.131:9092。
Zookeeper与Kafka运行在同一台虚拟机中。
在运行创建topic命令时,遇到两处报错:
1)报错:Exception in thread "main" joptsimple.UnrecognizedOptionException: zookeeper is not a recognized option
都说是因为新版本的kafka创建topic的方式改变了,不能继续使用--zookeeper创建了,要使用--bootstrap-server创建。
2)报错:Error while executing topic command : Timed out waiting for a node assignment. Call: createTopics
这是因为访问了错的端口,所以请求失败导致超时。需要使用Kafka端口,默认是9092。
综上,现在创建topic需要使用最新的kafka创建方式:需要把--zookeeper改为--bootstrap-server,且把端口号改为Kafka的端口号9092。
./kafka-topics.sh --create --bootstrap-server 192.168.154.131:9092 --replication-factor 1 --partitions 1 --topic test
列出所有以创建的topic,来查看是否创建成功:
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。