Consumers
This page describes the commands for managing Kafka consumers in Lenses via the CLI.
Commands for updating consumer groups offsets.
Flags --group and --topic are mandatory and specify the consumer group ID and topic name respectively.
To affect all topics use the —all-topics flag.
update-single-partition accepts only one --topic flag while update-multiple-partitions may accept multiple.
Update a single topic’s partition offset to the specified value
lenses-cli consumers \
offsets \
update-single-partition \
--group <group_name> \
--topic <topic_name> \
--partition <partition_id> \
--to-offset <offset_id>
Update to the earliest offset available
lenses-cli consumers \
offsets \
update-single-partition \
--group <group_name> \
--topic <topic_name> \
--partition <partition_id> \
--to-earliest
Update to the latest offset available
lenses-cli consumers \
offsets \
update-single-partition \
--group <group_name> \
--topic <topic_name> \
--partition <partition_id> \
--to-latest
Update given topics for all their partition offsets to the specified date time
lenses-cli consumers \
offsets \
update-multiple-partitions \
--group <group_name> \
--topic <topic_name> \
--to-datetime <datetime>
Reset given topics for all their partition offsets to the earliest offset possible
lenses-cli consumers \
offsets \
update-multiple-partitions \
--group <group_name> \
--topic <topic_name> \
--to-earliest
Reset given topics for all their partition offsets to the latest offset possible
lenses-cli consumers \
offsets \
update-multiple-partitions \
--group <group_name> \
--topic <topic_name> \
--to-latest
Reset offsets for all topics of this consumer group
lenses-cli consumers \
offsets \
update-multiple-partitions \
--group <group_name> \
--all-topics \
--to-latest