docker - kafka-avro-console-consumer is 命令在 `confluentinc/cp-enterprise-kafka` 中不可用

Question

我在 docker-compose.yml 文件下面

version: '2'

services:
zookeeper:
    image: confluentinc/cp-zookeeper:6.0.0
    hostname: zookeeper
    container_name: zookeeper
    ports:
    - "2181:2181"
    environment:
    ZOOKEEPER_CLIENT_PORT: 2181
    ZOOKEEPER_TICK_TIME: 2000

kafka:
    image: confluentinc/cp-enterprise-kafka:6.0.0
    hostname: kafka
    container_name: kafka
    depends_on:
    - zookeeper
    ports:
    - "29092:29092"
    environment:
    KAFKA_BROKER_ID: 1
    KAFKA_ZOOKEEPER_CONNECT: 'zookeeper:2181'
    KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
    KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092,PLAINTEXT_HOST://localhost:29092
    KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
    KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1

当我运行时，docker-compose exec kafka bash我得到 bash 提示。

在我的 bash 提示符中，kafka-console-consumer但我无权访问kafka-avro-console-consumer?

我怎样才能访问kafka-avro-console-consumer？它不在 $PATH 中，而是在其他目录中吗？

我尝试使用find和which命令，但在 docker running 容器中不存在这些命令

标签： dockerapache-kafkadocker-composeconfluent-platform

Answer 1

使用 confluentinc/cp-schema-registry

docker run confluentinc/cp-schema-registry \
 kafka-avro-console-consumer --bootstrap-server localhost:29092 --topic quickstart-jdbc-test --from-beginning --max-messages 10