4.2

You are viewing documentation for an older version of Lenses.io View latest documentation here

Kafka consumers

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.

  • -g, —group - Sets the Consumer Group ID
  • -t, —topic - Sets the topic name
  • —all-topics - Selects implicitly all topics
  • —-topic - The topic to reset offsets for
  • —partition - Sets the partition ID
  • —to-earliest - resets partition offset to earliest offset
  • —to-latest - sets partition offset to latest offset
  • —to-offset - sets 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 alls their partitions offsets to the specified datetime 

lenses-cli consumers \
    offsets \
    update-multiple-partitions \
    --group <group_name> \
    --topic <topic_name> \
    --to-datetime <datetime>

Reset given topics for all their partitions 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 partitions offsets to the earliest 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