...

Add an option to the streams reset tool.

internalTopicsOption = optionParser.accepts("

--internal-topics

", "Comma

 <String: list>    Comma-separated list of internal topics. 
                                     If specified, these are the only topics

topics

that

the

tool

will

attempt

to

delete.")

.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.

...