...
Add an option to the streams reset tool.
internalTopicsOption = optionParser.accepts("", "Comma <String: list> Comma-separated list of internal topics. If specified, these are the only topics |
topicsthatthetoolwillattempttodelete.").withRequiredArg().ofType(String.class).withValuesSeparatedBy(',') that the tool will attempt to delete. |
describedAs("list"); Proposed Changes
Add an internal-topics option to streams reset tool. If specified, these will be the only topics considered for deletion.
...
Usage of the "internal-topic" options will involve:
- Do a Run `kafka-streams-application-reset.sh` with `--dry-run run` to check the which internal topics that will be deleted.
- If everything looks okay, execute without run the script again without `--dry-runrun`. Otherwise, specify the set of internal-topics to be deleted with `--internal-topics`.
Compatibility, Deprecation, and Migration Plan
No compatibility issues. If the new option is not specified, the stream resetter's behaviour will remain unchanged.
...