How to use standard kafka-avro-console-consumer tool with Kafka running via Confluent Helm Chart ?

How to use standard kafka-avro-console-consumer tool with Kafka running via Confluent Helm Charts?

The confluentinc/cp-kafka:5.0.0 image recommended for running command line Interface utilities does not contain kafka-avro-console-consumer.

If I shell into the schema-registry pod to use 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)

Need help on this.
Thank in advance.

Tagged:

Comments

  • start the schema registry

    sudo sh /home/yourdir/confluent-5.1.0/bin/schema-registry-start /home/yourdir/kafka/bin/schema-registry.properties

    sudo sh /home/Lenovo/confluent-5.1.0/bin/kafka-avro-console-consumer --bootstrap-server host2:9092,host-1:9092,host-3:9092 --topic Mysql_kpro_transactional --from-beginning

Sign In or Register to comment.