Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

This option should be executed independently from other Consumer Group options (list, describe, delete, etc.) and it will only support new consumers.

Required Arguments

IDArgumentTypeDescriptio
1.--groupRequiredConsumer Group ID.
2.--bootstrap-serverRequiredServer to connect to.

Scenarios

At least one of the scenarios should be defined to proceed with the execution

...

Nevertheless, it is possible to achieve the same result since release 0.10.0 using timestamp metadata by record, doing a linear search starting from latest. However, we are not considering to support this option because it will be an expensive/slow option.

All the other options will be available for releases from 0.10.0.0 given that KIP-97 is implemented.

This KIP will not support old consumers that store offsets in Zookeeper.

Test Plan

  • A unit test to validate that --reset-offset is executed independently from other Consumer Group options (list, delete, describe, etc.)
  • A unit test to validate that only one scenario is specified
  • A unit test to validate that only one scope is specified
  • A unit test to validate that only one execution option is specified
  • A unit test by combination of scenario, scope and execution option.
  • A unit test to validate that when calculated offset by partition is older that the earliest offset, tool resets offset to earliest (e.g. when we specified --reset-to 0, when earliest offset is 10)
  • A unit test to validate that when calculated offset by partition is bigger that the latest offset, tool resets offset to latest (e.g. when we specified --reset-to 0, when earliest offset is 10)

...