THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Current state: Under Discussion vote
Discussion thread: https://lists.apache.org/thread.html/r2dc1cabfb75df6117bc464c29f0700dd1214fd1352bacfa99381b9bf%40%3Cdevrdc2c6426e957f68c311fde0752c6611666d3e00e5b7b8dcd69386906@%3Cdev.kafka.apache.org%3E
JIRA:
Jira | ||||||
---|---|---|---|---|---|---|
|
...
- A new resetAllExternalTopicsOption will be added for user to cleanup all externally committed offsets
- `--inputall-topic`and `--intermediate-topic` flag using regular expressionsuser-topics` flag add
Code Block | ||||
---|---|---|---|---|
| ||||
public class StreamsResetter { /* private static OptionSpecBuilder resetAllExternalTopicsOption; 'all-user-topics' add flag private void parseArguments(final String[] args) { */ private static ... resetAllExternalTopicsOption = optionParser.accepts("resetOptionSpecBuilder allUserTopicsOption; } |
Proposed Changes
- --all-
...
- user-topics Reset tool to delete offsets for all topics related to available groups
Compatibility, Deprecation, and Migration Plan
...