为什么kafka不创建主题？- 不是一个公认的选项

Question

我是 Kafka 新手，正在尝试在本地计算机上创建一个新主题。\n我正在关注此https://medium.com/@maftabali2k13/setting-up-a-kafka-cluster-on-ec2-1b37144cb4e

\n\n

\n
1. 启动动物园管理员
\n

\n\n

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties\n

\n\n

启动kafka服务器

\n\n

bin/kafka-server-start.sh -daemon config/server.properties\n

\n\n

创建主题

\n\n

bin/kafka-topics.sh --create -\xe2\x80\x93bootstrap-server localhost:9092 -\xe2\x80\x93replication-factor 1 -\xe2\x80\x93partitions 1 --topic jerry\n

\n\n

但是在创建主题时，出现以下错误

\n\n

\nException in thread "main" joptsimple.UnrecognizedOptionException: \xe2\x80\x93 is not a recognized option\n        at joptsimple.OptionException.unrecognizedOption(OptionException.java:108)\n        at joptsimple.OptionParser.validateOptionCharacters(OptionParser.java:633)\n        at joptsimple.OptionParser.handleShortOptionCluster(OptionParser.java:528)\n        at joptsimple.OptionParser.handleShortOptionToken(OptionParser.java:523)\n        at joptsimple.OptionParserState$2.handleArgument(OptionParserState.java:59)\n        at joptsimple.OptionParser.parse(OptionParser.java:396)\n        at kafka.admin.TopicCommand$TopicCommandOptions.<init>(TopicCommand.scala:552)\n        at kafka.admin.TopicCommand$.main(TopicCommand.scala:49)\n        at kafka.admin.TopicCommand.main(TopicCommand.scala)\n

\n\n

我看到了以下为什么卡夫卡不创建主题？bootstrap-server 不是一个可识别的选项\n但是我在这里找不到问题的答案，因为给出的错误不同。我在这里缺少一些东西吗？

\n

Answer 1

我使用过你的命令并遇到了同样的问题：

\n\n

bin/kafka-topics.sh --create -\xe2\x80\x93bootstrap-server localhost:9092 -\xe2\x80\x93replication-factor 1 -\xe2\x80\x93partitions 1 --topic jerry

\n\n

如果你仔细观察你的命令，你会发现 options: 和 之前的bootstrap-server选项很奇怪replication-factorpartitions。

\n\n

我认为您使用复制/粘贴方法并添加了一些奇怪的字符：

\n\n

以下命令应该有效：\nbin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic jerry

\n\n

最好的方法是自己写:)。

\n