创建Kafka Topic时出现KafkaAdminClient创建失败错误求助

核心错误原因 #

从报错信息org.apache.kafka.common.config.ConfigException: Invalid url in bootstrap.servers: 54.165.35.70:9092/test可以明确：你在--bootstrap-server参数中添加了多余的/test路径后缀。Kafka的bootstrap.servers只接受主机IP:端口的格式，不需要附加任何路径。

修正后的创建Topic命令 #

将原命令中的/test后缀全部删除，正确命令如下：

/opt/homebrew/bin/kafka-topics --create --bootstrap-server ip1:port,ip2:port,ip3:port --replication-factor 3 --partitions 1 --topic test

额外问题处理 #

1. OpenJDK GC线程配置警告 #

这属于JVM层面的警告，不影响Kafka核心功能。若要消除警告，可修改Kafka启动脚本（kafka-server-start.sh）中的JVM参数，根据t2.micro的1核CPU资源调整GC线程配置，示例：

# 在脚本的KAFKA_HEAP_OPTS后添加GC线程配置
export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G -XX:ParallelGCThreads=2 -XX:ConcGCThreads=1"

2. 后续验证与配置检查 #

• 网络连通性：确认本地Mac和EC2服务器之间能访问Kafka的9092端口（检查EC2安全组是否开放对应端口，本地防火墙是否放行）
• Kafka配置检查：核实server.properties中的listeners和advertised.listeners配置，确保集群对外暴露的地址是可访问的IP:端口格式
• ZooKeeper连通性：检查Kafka的server.properties中zookeeper.connect配置正确，且ZK集群正常运行

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