bitnami docker kafka：配置 message.max.bytes 的值无效

Question

我遇到一个问题：

Exception in thread "main" org.apache.kafka.common.config.ConfigException: Invalid value  for configuration message.max.bytes: Not a number of type INT

尝试在 Docker 内运行 bitnami 镜像 kafka 代理时。当我切换到 Macbook Pro M3 时，它就出现了。在英特尔 Macbook Pro 上，它开箱即用，运行流畅。我应该怎么做才能让这个 Kafka 实例正常工作？我已经通过brew安装了Java，但没有帮助。我的 docker-compose 文件如下所示：

services:
  kafka:
    image: &kafka-image bitnami/kafka:latest
    ports:
      - ${KAFKA_BROKER_PORT_1}:${KAFKA_BROKER_PORT_1}
    environment:
      - KAFKA_CFG_NODE_ID=0
      - KAFKA_CFG_PROCESS_ROLES=controller,broker
      - KAFKA_CFG_LISTENERS=PLAINTEXT://:9092,CONTROLLER://:9093,EXTERNAL://:${KAFKA_BROKER_PORT_1}
      - KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://kafka:9092,EXTERNAL://${KAFKA_BROKER_SERVER_1}:${KAFKA_BROKER_PORT_1}
      - KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,EXTERNAL:PLAINTEXT,PLAINTEXT:PLAINTEXT
      - KAFKA_CFG_CONTROLLER_QUORUM_VOTERS=0@kafka:9093
      - KAFKA_CFG_CONTROLLER_LISTENER_NAMES=CONTROLLER
      - KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE=true
      - KAFKA_CFG_MAX_REQUEST_SIZE=2097152
      - TEST_TOPIC_NAME=test
    volumes:
      - ./kafka_data:/bitnami/kafka
    healthcheck:
      test: ["CMD", "kafka-topics.sh", "--bootstrap-server=localhost:9092", "--list"]
      start_period: 15s
      interval: 10s

  # This service needs for setup kafka topics
  setup-kafka:
    image: *kafka-image
    working_dir: /opt/bitnami/kafka/bin
    entrypoint: /bin/bash
    depends_on:
      kafka:
        condition: service_healthy
    command: |
      kafka-topics.sh --create --if-not-exists --topic test --replication-factor=1 --partitions=1 --bootstrap-server kafka:9092

我认为问题出在 docker-compose 文件中，但我也尝试从清晰的 bitnami 图像运行实例。例如

  kafka_1:
    image: 'bitnami/kafka:latest'
    environment:
      - KAFKA_CFG_NODE_ID=0
      - KAFKA_CFG_PROCESS_ROLES=controller,broker
      - KAFKA_CFG_LISTENERS=PLAINTEXT://:9092,CONTROLLER://:9093
      - KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT
      - KAFKA_CFG_CONTROLLER_QUORUM_VOTERS=0@kafka:9093
      - KAFKA_CFG_CONTROLLER_LISTENER_NAMES=CONTROLLER

但是问题并没有消失。

Answer 1

将以下环境变量添加到环境部分：

KAFKA_CFG_MESSAGE_MAX_BYTES=20000000