当我在 kafka 中运行消费者脚本时，我收到错误 1 ​​分区有领导代理没有匹配的侦听器

Question

这是我的 docker-compose.yml 文件

version: '3'

services:
  zookeeper:
    image: 'bitnami/zookeeper:latest'
    ports:
      - 2181:2181
    environment:
      - ALLOW_ANONYMOUS_LOGIN=yes
  kafka:
    image: bitnami/kafka:latest
    depends_on:
    - zookeeper
    ports:
    - 9092:9092
    environment:
      - KAFKA_BROKER_ID=1
      - KAFKA_ADVERTISED_HOST_NAME=localhost
      - KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092
      - KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka:9092
      - KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
      - ALLOW_PLAINTEXT_LISTENER=yes
      - KAFKA_CREATE_TOPICS=kafkatutorial:1:1

20/11/01 17:11:33 WARN NetworkClient: [Producer clientId=producer-1] 1 个分区具有没有匹配侦听器的领导代理，包括 [kafkatutorial-0]

Answer 1

bitnami 容器不支持KAFKA_CREATE_TOPICS 变量，仅支持 wurstmeister

您需要手动创建主题