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