THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- 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 | ||||
---|---|---|---|---|
| ||||
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
...