我对Kafka很陌生,我想在本地机器上创建一个新的主题。我在关注这个https://medium.com/@maftabali2k13/setting-up-a-kafka-cluster-on-ec2-1b37144cb4e上
启动zookeeper
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
启动kafka服务器
bin/kafka-server-start.sh -daemon config/server.properties
创建主题
bin/kafka-topics.sh --create -–bootstrap-server localhost:9092 -–replication-factor 1 -–partitions 1 --topic jerry
但是在创建主题时,我遇到了以下错误
Exception in thread "main" joptsimple.UnrecognizedOptionException: – is not a recognized option
at joptsimple.OptionException.unrecognizedOption(OptionException.java:108)
at joptsimple.OptionParser.validateOptionCharacters(OptionParser.java:633)
at joptsimple.OptionParser.handleShortOptionCluster(OptionParser.java:528)
at joptsimple.OptionParser.handleShortOptionToken(OptionParser.java:523)
at joptsimple.OptionParserState$2.handleArgument(OptionParserState.java:59)
at joptsimple.OptionParser.parse(OptionParser.java:396)
at kafka.admin.TopicCommand$TopicCommandOptions.<init>(TopicCommand.scala:552)
at kafka.admin.TopicCommand$.main(TopicCommand.scala:49)
at kafka.admin.TopicCommand.main(TopicCommand.scala)
我已经看到了Kafka为什么不创造一个主题?引导服务器是一个不可识别的选项,但我找不到一个答案,我的问题,因为这里给出的错误是不同的。有什么东西是我遗漏的吗?
1条答案
按热度按时间2admgd591#
我用过你的命令也有同样的问题:
bin/kafka-topics.sh --create -–bootstrap-server localhost:9092 -–replication-factor 1 -–partitions 1 --topic jerry
如果您仔细观察您的命令,您将看到,在选项之前:bootstrap-server
,replication-factor
以及partitions
都是奇怪的人物。我觉得你用的是复制粘贴的方式,加了一些奇怪的字符:
以下命令应起作用:
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic jerry
最好的方法是自己写:)。