Кафка + Кубернетес + Шлем + `/usr/bin/kafka-avro-console-consumer`?

Question

Как мне использовать стандарт kafka-avro-console-consumer инструмент с Kafka, запущенным через Confluent Helm Charts? confluentinc/cp-kafka:5.0.0 изображение, рекомендованное для запуска утилиты cli, не содержит kafka-avro-console-consumer,

Если я шелл в модуль схемы реестра, чтобы использовать kafka-avro-console-consumer

kubectl exec -it my-confluent-oss-cp-schema-registry-6c8546c86d-pjpmd -- /bin/bash

/usr/bin/kafka-avro-console-consumer --bootstrap-server my-confluent-oss-cp-kafka:9092 --topic my-test-avro-records --from-beginning

Error: Exception thrown by the agent : java.rmi.server.ExportException: Port already in use: 5555; nested exception is: 
    java.net.BindException: Address already in use (Bind failed)
sun.management.AgentConfigurationError: java.rmi.server.ExportException: Port already in use: 5555; nested exception is: 
    java.net.BindException: Address already in use (Bind failed)
    at sun.management.jmxremote.ConnectorBootstrap.startRemoteConnectorServer(ConnectorBootstrap.java:480)
    at sun.management.Agent.startAgent(Agent.java:262)
    at sun.management.Agent.startAgent(Agent.java:452)
Caused by: java.rmi.server.ExportException: Port already in use: 5555; nested exception is: 
    java.net.BindException: Address already in use (Bind failed)

Answer 1

java.rmi.server.ExportException: порт уже используется: 5555;

Похоже, вы включили JMX как часть этого контейнера через KAFKA_JMX_PORT переменная.

Если это так, вам нужно будет временно переопределить это, экспортировав его в сеансе оболочки в другое значение, прежде чем запускать любые другие скрипты Kafka.