You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
35 lines
1.2 KiB
Plaintext
35 lines
1.2 KiB
Plaintext
# 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
|