为什么Kafka无法创建主题？bootstrap-server不是一个可识别的选项。

Question

我对Kafka很新，正在尝试在我的本地机器上创建一个新的主题。

我正在遵循这个链接。

以下是我遵循的步骤：

1. 启动Zookeeper

bin/zookeeper-server-start.sh config/zookeeper.properties

2. 启动 kafka-server

   bin/kafka-server-start.sh config/server.properties
   

   创建话题

   bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
   

   但是当我创建主题时，出现了以下错误：

   Exception in thread "main" joptsimple.UnrecognizedOptionException: bootstrap-server 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:358)
       at kafka.admin.TopicCommand$.main(TopicCommand.scala:44)
       at kafka.admin.TopicCommand.main(TopicCommand.scala)
   

   创建主题是否需要其他配置？我错在哪里了？

- KayV

Answer 1

如果您使用的是2.2版本以下的版本，您应该使用--zookeeper选项并将连接字符串传递给zookeeper。

命令应该类似于： bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

- Bartosz Wardziński

---

但是文档使用的是“bootstrap-server”。 - KayV

文档适用于 2.2 版本。我猜你正在使用 2.1 版本或更早的版本。 - Bartosz Wardziński

文档是针对2.12版本的，而我正在使用2.11版本。 - KayV

"2.12"或"2.11"是Scala版本，不是Kafka版本。 "kafka_2.12-2.1.0"表示它是Kafka 2.1.0版本。" - Bartosz Wardziński