kafka-client
Usage:
Produce:
docker run -ti --rm incu6us/kafka-client kafka-console-producer.sh --topic mega-topic --broker-list 172.16.0.1:9094
Consume:
docker run -ti --rm incu6us/kafka-client kafka-console-consumer.sh --topic mega-topic --bootstrap-server 172.16.0.1:9094
Create topic:
docker run -ti --rm incu6us/kafka-client kafka-topics.sh --create --bootstrap-server 172.16.0.1:9094 --replication-factor 1 --partitions 1 --topic mega-topic
List group:
docker run -ti --rm incu6us/kafka-client kafka-consumer-groups.sh --bootstrap-server 172.16.0.1:9094 --list
Describe group:
docker run -ti --rm incu6us/kafka-client kafka-consumer-groups.sh --bootstrap-server 172.16.0.1:9094 --group test-group --describe