Versions Compared

Key

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

...

Code Block
languagejava
titleadd reset-all-external-topics option
private static OptionSpecBuilder resetAllExternalTopicsOption;

private int maybeResetInputAndSeekToEndIntermediateTopicOffsets(final Map consumerConfig,
																final boolean dryRun,
                                                                final boolean resetAllExternalTopics)


Proposed Changes

We could add a config `--reset-all-external-topics` to the reset tool such that when enabled, we could delete offsets for all involved topics. The topic metadata could be acquired by issuing a `DescribeGroup` request from admin client, which is stored in the member subscription information.

...