Apache Kafka

Consumer Groups Commands

Consumer groups enable parallel processing and fault tolerance. Learn to inspect, manage, and reset consumer group offsets.

6 commands

Pro Tips

Use --describe to check consumer lag - high lag indicates slow processing.

Use --dry-run with reset-offsets to preview changes before applying.

Common Mistakes

Stop all group members before resetting offsets to avoid conflicts.

Commands

List groups

$ kafka-consumer-groups.sh --list --bootstrap-server localhost:9092

List all consumer groups.

Describe group

$ kafka-consumer-groups.sh --describe --group my-group --bootstrap-server localhost:9092

Show group members and lag.

Reset offset to earliest

$ kafka-consumer-groups.sh --group my-group --topic my-topic --reset-offsets --to-earliest --execute --bootstrap-server localhost:9092

Reset group offset to beginning.

Reset offset to latest

$ kafka-consumer-groups.sh --group my-group --topic my-topic --reset-offsets --to-latest --execute --bootstrap-server localhost:9092

Reset group offset to end.

Reset by timestamp

$ kafka-consumer-groups.sh --group my-group --topic my-topic --reset-offsets --to-datetime 2024-01-01T00:00:00.000 --execute --bootstrap-server localhost:9092

Reset offset to specific timestamp.

Delete group

$ kafka-consumer-groups.sh --delete --group my-group --bootstrap-server localhost:9092

Delete a consumer group.