[root@hadoop01 bin]# ./kafka-topics.sh --create --topic test Exception in thread "main" java.lang.IllegalArgumentException: --bootstrap-server must be specified at kafka.admin.TopicCommand$TopicCommandOptions.checkArgs(TopicCommand.scala:568) at kafka.admin.TopicCommand$.main(TopicCommand.scala:48) at kafka.admin.TopicCommand.main(TopicCommand.scala)

<think>我们正在处理一个关于Kafka命令行工具创建主题时出现的错误。错误信息明确指出"--bootstrap-servermust bespecified"，这意味着我们在执行命令时没有提供必需的--bootstrap-server参数。根据引用[1]和[2]，我们知道在使用Kafka命令行工具（如kafka-topics.sh）时，不能同时使用--bootstrap-server和--zookeeper参数，因为它们是互斥的。从Kafka的某个版本开始（具体是Kafka2.2.0之后），官方推荐使用--bootstrap-server参数而不是--zookeeper参数，因为使用ZooKeeper的方式已经被标记为过时（deprecated）。用户遇到的错误是因为在命令中缺少了--bootstrap-server参数。可能用户只指定了--zookeeper参数，或者两个参数都没有指定。根据错误提示，我们需要指定--bootstrap-server。正确的创建主题的命令应该使用--bootstrap-server参数，并指定Kafka broker的地址（通常是host:port形式，多个用逗号分隔）。例如：bin/kafka-topics.sh--create--bootstrap-serverlocalhost:9092 --topic my_topic --partitions1--replication-factor1但是，如果用户的Kafka版本较旧（低于2.2.0），则可能需要使用--zookeeper参数。不过，错误提示要求的是--bootstrap-server，所以我们可以推断用户使用的是较新的版本（2.2.0及以上），因此必须使用--bootstrap-server。另外，引用[4]中展示了一些命令示例，其中创建主题时使用了--zookeeper参数，这可能是旧版本的用法。而引用[5]提到了Flume启动错误中也有类似的提示，说明缺少Bootstrap Servers，这进一步印证了在新版本中必须使用--bootstrap-server。因此，解决方案是：在创建主题的命令中，使用--bootstrap-server参数并指定一个或多个Kafka broker的地址，而不是使用--zookeeper参数。步骤：1.确认Kafka集群的broker地址。通常，broker的地址格式为`主机名:端口`，默认端口是9092。如果有多个broker，用逗号分隔（但不需要全部指定，指定一个或多个即可）。2.使用正确的命令格式创建主题。示例命令：kafka-topics.sh--create--bootstrap-serverkafka-broker1:9092,kafka-broker2:9092--topictest-topic --partitions3--replication-factor2注意：--partitions和--replication-factor是创建主题时的重要参数，需要根据实际情况指定。如果用户之前使用的是--zookeeper参数，现在需要改为--bootstrap-server参数，并确保指定的broker地址正确且可访问。另外，如果用户的环境变量中没有配置Kafka的bin目录，可能需要使用完整路径，例如：/path/to/kafka/bin/kafka-topics.sh--create--bootstrap-server localhost:9092--topicmy_topic --partitions1--replication-factor1如果用户仍然遇到问题，可以检查Kafka服务是否正在运行，以及--bootstrap-server指定的地址和端口是否正确。相关问题：1.如何检查Kafkabroker是否可用？2.创建Kafka主题时，如何确定分区数和副本因子？3.为什么新版本的Kafka推荐使用--bootstrap-server而不是--zookeeper？</think>### Kafka创建主题错误修复指南 当使用Kafka命令行工具创建主题时出现`--bootstrap-server must be specified`错误，表示命令缺少必需的参数。以下是修复步骤和原理分析： #### 错误原因 1. **参数冲突**：Kafka 2.2+版本要求只能使用`--bootstrap-server`或`--zookeeper`中的一个参数，不能同时使用[^1][^2] 2. **版本兼容性**：新版本Kafka（≥2.2）已弃用`--zookeeper`参数，强制要求使用`--bootstrap-server`连接Kafka broker[^4] 3. **参数缺失**：命令中未提供必需的broker地址信息 #### 修复步骤 1. **确认Kafka版本**： ```bash kafka-topics.sh --version ``` 若版本≥2.2，必须使用`--bootstrap-server` 2. **正确命令格式**： ```bash # 创建主题标准命令 kafka-topics.sh --create \ --bootstrap-server <broker1:port>,<broker2:port> \ --topic <topic_name> \ --partitions <num> \ --replication-factor <num> # 示例（单节点） kafka-topics.sh --create \ --bootstrap-server localhost:9092 \ --topic test_topic \ --partitions 3 \ --replication-factor 1 ``` 3. **关键参数说明**： - `--bootstrap-server`：指定Kafka broker地址（多个用逗号分隔） - `--partitions`：分区数（≥1） - `--replication-factor`：副本数（≤broker数量） 4. **验证主题创建**： ```bash kafka-topics.sh --list --bootstrap-server localhost:9092 ``` #### 注意事项 1. 确保broker地址正确且Kafka服务正在运行 2. 生产环境建议指定至少3个broker地址提高容错性 3. 若需使用ZooKeeper（旧版兼容），命令格式应为： ```bash kafka-topics.sh --create --zookeeper localhost:2181 ... ``` 但新版本强烈不推荐此方式[^4] #### 原理分析 Kafka从2.2版本开始逐步迁移到Kafka Raft协议，减少对ZooKeeper的依赖。`--bootstrap-server`直接连接Kafka控制器节点，而`--zookeeper`连接ZooKeeper协调服务。两者协议栈不同导致参数互斥[^2][^4]。 > **引用说明**：Kafka命令行工具参数冲突问题源于协议栈的版本演进[^1][^2]，新版本强制要求使用`--bootstrap-server`参数直接连接broker节点[^4][^5]。