AWS EC2部署3节点Kafka集群创建Topic时提示等待节点分配超时

1. 修正核心配置错误 #

你当前的配置存在两个致命问题，是创建Topic超时的核心原因：

• listener.security.protocol.map语法错误：所有broker的该配置开头多了多余逗号，会导致协议映射解析失败，broker无法识别通信协议。
• inter.broker.listener.name配置不统一：该参数是集群全局通用配置，要求所有broker使用相同的内部通信监听器名称，你当前三个节点分别定义了PLAINTEXT_1/PLAINTEXT_2/PLAINTEXT_3，broker之间无法完成内部通信，虽然能注册到ZooKeeper，但元数据同步、副本分配逻辑完全无法执行。

你可以参考以下规范调整所有节点配置，统一内部监听器名称：

kafka-1调整后示例 #

broker.id=0
# listeners建议绑定0.0.0.0，EC2实例网卡没有直接绑定公网IP，直接绑定公网域名可能启动失败
listeners=PLAINTEXT_INTERNAL://0.0.0.0:9092
advertised.listeners=PLAINTEXT_INTERNAL://ec2-**-***-**-17.eu-central-1.compute.amazonaws.com:9092
listener.security.protocol.map=PLAINTEXT_INTERNAL:PLAINTEXT
inter.broker.listener.name=PLAINTEXT_INTERNAL
zookeeper.connect=ec2-**-***-**-105.eu-central-1.compute.amazonaws.com:2181

其余两个broker仅需要调整listeners/advertised.listeners的地址端口，inter.broker.listener.name、listener.security.protocol.map保持和所有节点一致即可。

2. 验证集群通信状态 #

修改配置重启所有broker后，在任意broker节点执行以下命令验证集群节点互通性：
./kafka-broker-api-versions.sh --bootstrap-server <当前节点地址:端口>
正常返回结果会包含所有在线broker的ID和支持的API版本，如果仅能看到当前节点，说明内部通信依然异常，可进一步检查EC2安全组是否放行了所有broker之间的对应端口、监听器配置是否正确。

3. 检查控制器日志定位细节 #

如果调整配置后依然报错，可以先在ZooKeeper执行命令找到当前集群的控制器节点：
get /controller
返回结果会包含控制器的broker ID，登录对应节点查看controller.log和server.log，创建Topic时的具体阻塞原因都会在日志中明确打印。

4. 验证Topic创建 #

集群状态正常后，重新执行Topic创建命令即可。

内容的提问来源于stack exchange，提问作者fallen