From 16e40d1c0f344f73951186d989a513b9e2ccaa58 Mon Sep 17 00:00:00 2001 From: Alexander Popov Date: Thu, 27 Jun 2019 14:18:24 +0300 Subject: [PATCH] Add cheatsheet for kafka-consumer-groups cli --- sheets/kafka-consumer-groups | 34 ++++++++++++++++++++++++++++++++++ 1 file changed, 34 insertions(+) create mode 100644 sheets/kafka-consumer-groups diff --git a/sheets/kafka-consumer-groups b/sheets/kafka-consumer-groups new file mode 100644 index 0000000..a42395e --- /dev/null +++ b/sheets/kafka-consumer-groups @@ -0,0 +1,34 @@ +# kafka-consumer-groups +# +# A command-line tool to manage Kafka consumer groups +# +# see https://kafka.apache.org/documentation/#basic_ops_consumer_group + +# list all consumer groups +kafka-consumer-groups --bootstrap-server localhost:9092 --list + +# describe a consumer group +kafka-consumer-groups --bootstrap-server localhost:9092 \ + --group group-name \ + --describe + +# reset consumer offsets for a topic to the earliest offset +kafka-consumer-groups --bootstrap-server localhost:9092 \ + --group group-name \ + --reset-offsets \ + --to-earliest \ + --topic topic-name \ + --execute + +# reset consumer offsets for all topics to the earliest offset +kafka-consumer-groups --bootstrap-server localhost:9092 \ + --group group-name \ + --reset-offsets \ + --to-earliest \ + --all-topics \ + --execute + +# delete a consumer group +kafka-consumer-groups --bootstrap-server localhost:9092 \ + --group group-name \ + --delete