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.
Flag
Description
-g, --group
Set the Consumer Group ID
-t, --topic
Set the topic name
--all-topics
Select implicitly all the topics
--topics
The topic to reset offsets for
--partition
Set the partition ID
--to-earliest
Reset partition offset to earliest offset
--to-latest
Reset partition offset to latest offset
--to-offset
Reset the partition offset to the provided value
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
Last updated
Was this helpful?