1 of 1

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-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