我是 kafka 和 zookepper 的新手,我正在尝试创建一个主题,但我收到此错误 -
Exception in thread "main" joptsimple.UnrecognizedOptionException: zookeeper is not a recognized option
at joptsimple.OptionException.unrecognizedOption(OptionException.java:108)
at joptsimple.OptionParser.handleLongOptionToken(OptionParser.java:510)
at joptsimple.OptionParserState$2.handleArgument(OptionParserState.java:56)
at joptsimple.OptionParser.parse(OptionParser.java:396)
at kafka.admin.TopicCommand$TopicCommandOptions.<init>(TopicCommand.scala:517)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:47)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
Run Code Online (Sandbox Code Playgroud)
我正在使用此命令来创建主题 -
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partions 1 --topic TestTopic
Run Code Online (Sandbox Code Playgroud)
小智 153
Kafka 的较新版本(2.2+)不再需要 ZooKeeper 连接字符串
--zookeeper localhost:2181
创建主题时抛出以下异常
线程“main”中的异常 joptsimple.UnrecognizedOptionException:zookeeper 不是可识别的选项
相反,添加 Kafka Broker--bootstrap-server localhost:9092
连接字符串。
./kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 4
Run Code Online (Sandbox Code Playgroud)
Gir*_*buC 11
在最新版本kafka_2.12-3.1.0(2022)中解压并设置属性和日志后。将 Kafka 文件夹保留在 C 驱动器上,并始终使用“以管理员身份运行”运行命令提示符。.bat 文件适用于 Windows
1号航站楼
C:\kafka\bin\windows>zookeeper-server-start.bat ..\..\config\zookeeper.properties
第2航站楼
C:\kafka\bin\windows>kafka-server-start.bat ..\..\config\server.properties
第3航站楼
C:\kafka\bin\windows>kafka-topics.bat --create --topictutorialspedia --bootstrap-server localhost:9092
Created topic tutorialspedia.
到已创建主题的清单
C:\ kafka \ bin \ windows> kafka-topics.bat --list --bootstrap-server localhost:9092
tutorialspedia
归档时间: |
|
查看次数: |
64460 次 |
最近记录: |