confluentinc/cp-kafkacat pulls statistics

kafkacat Docker image

kafkacat is a commandline tool for interacting with Kafka brokers. It can be used to produce and consume messages, as well as query metadata.

The docker image for kafkacat would typically be used in conjunction with Kafka running in a docker environment. The important thing is to understand the networking context of the docker container and the associated Kafka broker to which kafkacat is to connect.

The below examples show how to use the kafkacat Docker image. For general reference on usage of kafkacat see here.

Listing topics on a broker

Assuming your Kafka broker is accessible as kafka:29092 on the Docker network docker-compose_default, you can list topics by running:

Consuming messages from a topic

Assuming your Kafka broker is accessible as kafka:29092 on the Docker network docker-compose_default, you can print messages and their associated metadata from topic foo, as follows:

Producing messages from a file on the host machine

kafkacat can produce messages into Kafka from a flat file. Assuming you have a file called /tmp/my_msgs.txt on the host machine from which you're running Docker, you would run the following to have kafkacat send these messages to the broker accessible as kafka:29092 on the Docker network docker-compose_default:

Producing messages inline from a script

This will send two messages, key/value 1/FOO and 2/BAR respectively. It assumes that your Kafka broker is accessible as kafka:29092 on the Docker network docker-compose_default.

License

Usage of this image is subject to the license terms of the software contained within. Please refer to Confluent's Docker images documentation reference for further information. The software to extend and build the custom Docker images is available under the Apache 2.0 License.

Description from the Docker Hub listing.