...

Status

Current state: Under DiscussionDiscussion vote

Discussion thread: https://lists.apache.org/thread.html/r1d7fb7b75a4523007d0768aed056b08ad18046b604480d219a31ebe2%40%3Cdevrdc2c6426e957f68c311fde0752c6611666d3e00e5b7b8dcd69386906@%3Cdev.kafka.apache.org%3E

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

...