[KAFKA-7930] StreamsResetter makes "changelog" topic naming assumptions

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.1.0
• Fix Version/s: 2.3.0
• Component/s: streams, tools
• Labels: features needs-kip patch-available usability
• Assignee: Murad M
• Reporter: Murad M
• Created: 14/Feb/19 00:37
• Updated: 21/Feb/19 07:47
• Resolved: 21/Feb/19 07:44

Description

StreamsResetter deletes the topics considered internal. Currently it just checks the naming as per code. If assumption is wrong (either topic prefix or suffix), tool becomes useless if aware even dangerous if not. Probably better either:

• naming assumption should be optional and supply internal topics with argument (--internal-topics)
• deletion could be optional (--no-delete-internal)
• ignore topics which are included in list of --input-topics

Faced this, when was trying to reset applications with GlobalKTable topics named as *-changelog. Such topics sometimes are not desirable for deletion.

Issue Links

• links to: GitHub Pull Request #6267