【问题标题】:kafka-avro-console-consumer is command is not available in `confluentinc/cp-enterprise-kafka`kafka-avro-console-consumer is 命令在 `confluentinc/cp-enterprise-kafka` 中不可用
【发布时间】:2021-03-02 18:07:04
【问题描述】:

我在 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 中,而是在其他目录中吗?

我尝试使用 findwhich 命令,但 docker running 容器中不存在这些命令

【问题讨论】:

    标签: docker apache-kafka docker-compose confluent-platform


    【解决方案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
    

    【讨论】:

      猜你喜欢
      • 2023-03-09
      • 2021-12-28
      • 2017-06-06
      • 1970-01-01
      • 2021-12-18
      • 1970-01-01
      • 2016-06-06
      • 2019-12-29
      • 2021-11-25
      相关资源
      最近更新 更多