本地运行应用时Kafka分区无法分配，节点ID显示-1求助

Docker Compose配置 #

kafka:
    image: bitnami/kafka:latest
    container_name: kafka
    restart: always
    deploy:
      resources:
        limits:
          memory: 1024M
    ports:
      - '9092:9092'
    volumes:
      - "kafka_data_storage:/bitnami"
    environment:
      KAFKA_CFG_NODE_ID: 0
      KAFKA_CFG_PROCESS_ROLES: controller,broker
      ALLOW_PLAINTEXT_LISTENER: "yes"
      KAFKA_CFG_LISTENERS: INTERNAL://:19092,CONTROLLER://:9093,EXTERNAL://:9092
      KAFKA_CFG_ADVERTISED_LISTENERS: INTERNAL://kafka:19092,EXTERNAL://localhost:9092
      KAFKA_CFG_INTER_BROKER_LISTENER_NAME: INTERNAL
      KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP: INTERNAL:PLAINTEXT,CONTROLLER:PLAINTEXT,EXTERNAL:PLAINTEXT
      KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE: "false"
      KAFKA_CFG_CONTROLLER_QUORUM_VOTERS: 0@kafka:9093
      KAFKA_CFG_CONTROLLER_LISTENER_NAMES: CONTROLLER
    healthcheck:
      test: [ "CMD", "kafka-topics.sh", "--list", "--bootstrap-server", "localhost:9092" ]
      interval: 10s
      timeout: 10s
      retries: 5

Spring Kafka服务配置 #

kafka:
    bootstrap-servers:
      - localhost:9092
    producer:
      client-id: some-client-id
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      value-serializer: org.apache.kafka.common.serialization.StringSerializer
    consumer:
      group-id: some-client-id
      auto-offset-reset: earliest
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer

正常运行时日志 #

INFO 1 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer    : some-client-id: partitions assigned: [some-topic-0]

异常日志（重复输出） #

INFO 45520 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-some-client-1, groupId=some-client] Disconnecting from node -1 due to request timeout.
INFO 45520 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-some-client-1, groupId=some-client] Cancelled in-flight API_VERSIONS request with correlation id 8 due to node -1 being disconnected (elapsed time since creation: 32563ms, elapsed time since send: 32563ms, request timeout: 30000ms)
WARN 45520 --- [ntainer#0-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-some-client-1, groupId=some-client] Bootstrap broker localhost:9092 (id: -1 rack: null) disconnected

已尝试的无效解决方法 #

• 清理并重新运行Compose
• 删除镜像后重新拉取并启动Compose
• 降级Kafka版本
• 重启电脑

核心疑问 #

同一Compose中的容器服务可正常连接Kafka，但本地运行的服务完全无法连接，且日志中节点ID显示为*-1*，这是为什么？

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