Kafka 生产者错误“1 个分区具有没有匹配侦听器的领导代理”答案

【问题标题】：Kafka producer error "1 partitions have leader brokers without a matching listener"Kafka 生产者错误“1 个分区具有没有匹配侦听器的领导代理”
【发布时间】：2020-11-11 02:46:42
【问题描述】：

第一次使用 Kafka 和 Docker-compose。我正在尝试向 Kafka 发布消息，但出现错误（如下所示）。有什么问题？

2020-07-21 16:37:40,274 警告 [kafka-producer-network-thread | producer-1] org.apache.kafka.clients.NetworkClient$DefaultMetadataUpdater: [Producer clientId=producer-1] 1 个分区有没有匹配监听器的领导代理，包括 [demo-topic-0]

这是我的 docker-compose.yml：

version: '3'

services:
  zookeeper:
    image: wurstmeister/zookeeper
    ports:
      - "2181:2181"
  kafka:
    image: wurstmeister/kafka
    links:
      - zookeeper:zk
    ports:
      - "9092:9092"
    expose:
      - "9093"
    environment:
      KAFKA_ZOOKEEPER_CONNECT: zk:2181
      KAFKA_MESSAGE_MAX_BYTES: 2000000
      KAFKA_CREATE_TOPICS: "demo-topic:1:1"
      KAFKA_BROKER_ID: 1
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9093,PLAINTEXT_HOST://localhost:9092
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
      KAFKA_LISTENERS: PLAINTEXT://kafka:9093,PLAINTEXT_HOST://localhost:9092
      KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock
    depends_on:
      - zookeeper

  player-service-ci:
    image: player/player-service:latest
    container_name: player-service-ci
    restart: unless-stopped
    volumes:
      - /tmp/app/logs:/logs
    environment:
      - "JAVA_OPTS=-Xmx256m -Xms128m"
      - "spring.profiles.active=ci"
      - "LOGS_FILENAME=player-service-logger-ci"
      - "SPRING_KAFKA_BOOTSTRAPSERVERS=kafka:9093"
    ports:
      - 17500:17500

networks:
  default:
    external:
      name: ci

【问题讨论】：

标签： docker apache-kafka docker-compose

【解决方案1】：

我的问题在Leader brokers without a matching listener error in kafka得到了部分回答。

docker-compose rm -sfv

以上代码最终解决了多个消费者的问题。

【讨论】：