Check Kafka Topic Ingestion

There are a few ways that you can accomplish this

HELK’s Kafka broker container

Access your kafka broker container by running the following command:

sudo docker exec -ti helk-kafka-broker bash

Run the script available in the container:

/opt/helk/kafka/bin/ --bootstrap-server helk-kafka-broker:9092 --topic winlogbeat --from-beginning

or simply run the script without an interactive shell

sudo docker exec -ti helk-kafka-broker /opt/helk/kafka/bin/ --bootstrap-server helk-kafka-broker:9092 --topic winlogbeat --from-beginning


It is generic non-JVM producer and consumer for Apache Kafka >=0.8, think of it as a netcat for Kafka. You can install it by following the instructions from the Kafkacat repo.

kafkacat -b -t winlogbeat -C