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

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

0 голосов
/ 25 октября 2018

Как использовать стандартный инструмент kafka-avro-console-consumer с Kafka, работающим через диаграммы Confluent Helm?Образ 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)

1 Ответ

0 голосов
/ 26 октября 2018

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

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

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

...