This page is meant as a template for writing a KIP. To create a KIP choose Tools->Copy on this page and modify with your content and replace the heading with the next KIP number and a description of your issue. Replace anything in italics with your own description.

Status

Current state: Under DiscussionDiscussion vote

Discussion thread: https://lists.apache.org/thread.html/rdc2c6426e957f68c311fde0752c6611666d3e00e5b7b8dcd69386906@%3Cdev.kafka.apache.org%3Ehere 

JIRA:

Motivation

...

• 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

Public Interfaces

• A new resetAllExternalTopicsOption will be added for user to cleanup all externally committed offsets
• `--all-user-topics` flag add

So we want to reset all related topics with one option.

Public Interfaces

StreamsResetter.class

...

public class StreamsResetter {
	 /*
    'all-user-topics' add flag
     */
    private static OptionSpecBuilder resetAllExternalTopicsOptionallUserTopicsOption;
}

Proposed Changes

...

• --

...

• all-

...

• user-

...

• topics Reset tool to delete offsets for all

...

 Added '--reset-all-external-topics' option
• topics related to available groups

Compatibility, Deprecation, and Migration Plan

...