GCP单节点Kafka创建Topic报错：Timed out waiting for a node assignment

通过GCP Marketplace的Click-to-Deploy部署单节点Kafka后，碰到以下问题：

1. server.properties配置文件里listeners配置重复：
   • 一处在Socket Server Settings区块下，处于注释状态
   • 另一处在Group Coordinator Settings区块下，未被注释
2. 创建Kafka Topic时触发超时错误：

   Error while executing topic command : Timed out waiting for a node assignment. Call: createTopics

3. 试了好几个创建Topic的命令，全返回同样的错误：

   kafka-topics.sh --zookeeper localhost:2181 --create --topic TestKafkaTopic --partitions 1 --replication-factor 1
   kafka-topics.sh --zookeeper localhost:9092 --create --topic TestKafkaTopic --partitions 1 --replication-factor 1
   kafka-topics.sh --create --bootstrap-server localhost:2181 --replication-factor 1 --partitions 1 --topic TestKafkaTopic
   kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic TestKafkaTopic
   kafka-topics.sh --create --bootstrap-server 127.0.0.1:9092 --replication-factor 1 --partitions 1 --topic TestKafkaTopic
   

1. 修正server.properties里的listeners配置 #

Kafka的listeners用来定义服务监听的网络地址，重复配置会导致服务启动后无法正常对外提供服务，按以下步骤修改：

• 打开server.properties文件（一般路径为/opt/kafka/config/server.properties，可根据GCP实际部署路径调整）
• 找到所有listeners相关配置，仅保留Group Coordinator Settings下未注释的那一行，删除或注释掉另一处重复项
• 确保listeners配置值正确，单节点环境建议设置为：

  listeners=PLAINTEXT://0.0.0.0:9092
  

• 同时检查advertised.listeners（如果存在该配置），需与listeners保持一致：

  advertised.listeners=PLAINTEXT://<你的GCP实例内部IP/公网IP>:9092
  

  若为本地访问，也可设置为PLAINTEXT://localhost:9092或PLAINTEXT://127.0.0.1:9092

2. 重启Kafka服务 #

配置修改后必须重启Kafka才能生效：

# 停止Kafka服务
systemctl stop kafka
# 启动Kafka服务
systemctl start kafka

如果使用的是GCP Click-to-Deploy的默认启动脚本，也可通过实例的服务管理界面重启Kafka

3. 使用正确的命令创建Topic #

你之前的部分命令存在参数错误（比如混用ZooKeeper端口2181和Kafka端口9092），正确命令分两种：

方式1：用ZooKeeper（适合旧版Kafka，新版不推荐） #

kafka-topics.sh --zookeeper localhost:2181 --create --topic TestKafkaTopic --partitions 1 --replication-factor 1

方式2：用Bootstrap Server（推荐，适合Kafka 2.2及以上版本） #

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

4. 先验证服务状态再创建Topic #

创建Topic前，先确认Kafka和ZooKeeper正常运行：

• 检查ZooKeeper状态：

  zkServer.sh status
  

• 检查Kafka进程：

  ps aux | grep kafka
  

• 尝试连接Kafka服务：

  kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test
  

  若能正常进入生产者交互界面，说明Kafka服务无问题

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