Kafkacat: una herramienta indispensable para controlar los topics
kafkacat es una utilidad de línea de comandos que se puede utilizar para probar y depurar las implementaciones de Apache Kafka. Puedes utilizar kafkacat para producir, consumir y listar información de temas y particiones para Kafka. Descrito como «netcat para Kafka», es una navaja suiza de herramientas para inspeccionar y crear datos en Kafka.
Para instalar kafkacat
sudo apt-get update sudo apt-get install kafkacat
Comando para listar los topics (donde localhost puede ser la ip del nodo)
kafkacat -b localhost:9092 -L
Para ver lo que llega a un topic testtopic
kafkacat -C -b 0.0.0.0:9092 -t testtopic
Para publicar, pulsar enter y escribir
kafkacat -P -b 0.0.0.0:9092 -t testtopic
Más información en Kafkacat Utility