Windows 10环境Minikube集群中Strimzi部署Kafka后外部连接超时问题排查

你的核心问题出在Kafka外部监听器的advertised地址配置缺失，另外还有几个需要验证的细节，我一步步给你拆解：

1. 修复Kafka监听器的advertised配置 #

Strimzi的nodeport类型外部监听器默认会把Pod的hostname作为advertised地址，这个地址对于Minikube外部的客户端是不可访问的。你需要手动指定Minikube的IP和对应的NodePort作为advertised地址，修改你的Kafka YAML配置：

apiVersion: kafka.strimzi.io/v1beta1
kind: Kafka
metadata:
  name: my-cluster
spec:
  kafka:
    version: 2.3.0
    replicas: 1
    listeners:
      external:
        type: nodeport
        tls: false
        advertisedHost: 192.168.49.2  # 你的Minikube IP
        advertisedPort: 32372         # my-cluster-kafka-external-bootstrap的NodePort
        nodePort: 32372               # 可选：固定NodePort，避免重启后端口变化
    config:
      offsets.topic.replication.factor: 1
      transaction.state.log.replication.factor: 1
      transaction.state.log.min.isr: 1
      log.message.format.version: "2.3"
    storage:
      type: persistent-claim
      size: 1Gi
  zookeeper:
    replicas: 1
    storage:
      type: persistent-claim
      size: 2Gi
      deleteClaim: false
  entityOperator:
    topicOperator: {}
    userOperator: {}

修改后重新应用配置：

kubectl apply -f your-kafka-config.yaml -n kafka

等待Kafka集群重启完成（可以用kubectl rollout status statefulset my-cluster-kafka -n kafka查看状态）。

2. 验证监听器配置是否生效 #

查看Kafka Pod的日志，确认advertised监听器地址正确：

kubectl logs -n kafka my-cluster-kafka-0 -c kafka | grep "Advertised listener"

你应该能看到类似这样的输出：

[2024-XX-XX XX:XX:XX,XXX] INFO Advertised listener: PLAINTEXT://192.168.49.2:32372 (org.apache.kafka.clients.Server)

3. 测试端口可达性 #

在Windows宿主机上用telnet或PowerShell命令测试Minikube的NodePort是否能访问：

telnet 192.168.49.2 32372

或者用PowerShell：

Test-NetConnection 192.168.49.2 -Port 32372

如果连接失败，检查Windows防火墙是否允许该端口的入站连接，或者暂时关闭防火墙测试。

4. 正确使用客户端连接 #

用Kafka控制台生产者连接时，要明确指定security.protocol=PLAINTEXT（因为你禁用了TLS）：

kafka-console-producer.sh --bootstrap-server 192.168.49.2:32372 --topic test-topic --producer-property security.protocol=PLAINTEXT

如果是用Windows本地的Kafka客户端，确保客户端版本和Kafka集群版本（2.3.0）尽量兼容，避免版本不匹配导致的连接问题。

额外注意点 #

• 不要直接连接my-cluster-kafka-0的NodePort（30117），这个是单个Broker的端口，外部客户端应该连接my-cluster-kafka-external-bootstrap的NodePort（32372），由bootstrap服务自动路由到可用的Broker。
• 如果后续重启Minikube后IP变化，记得更新advertisedHost的值。

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