Versions Compared

Key

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

...

  • user has to specify input topic name in the stream reset tool in order to purge its offsets
  • Adding a new option which could automatically detect all external topics and reset their corresponding offsets

  • Extend input to add the ability to reset multiple inputs simultaneously

...

Public Interfaces

  • A new resetAllExternalTopicsOption will be added for user to cleanup all externally committed offsets
  • `--input-topic` flag using regular expressions


Code Block
languagejava
titleadd reset-all-external-topics option
public class StreamsResetter {
    private static OptionSpecBuilder resetAllExternalTopicsOption;

Proposed Changes

...



    private void parseArguments(final String[] args) {
        ...
        resetAllExternalTopicsOption = optionParser.accepts("reset-all-external-

...

topics", "Reset tool such that when enabled, delete offsets for all involved topics");
    }
}

Compatibility, Deprecation, and Migration Plan

...