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

Public Interfaces

StreamsResetter.class

...

privatepublic staticclass OptionSpecBuilder resetAllExternalTopicsOption;

private int maybeResetInputAndSeekToEndIntermediateTopicOffsets(final Map consumerConfig,
																final boolean dryRun,
                                                                final boolean resetAllExternalTopics)

Proposed Changes

...

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

Proposed Changes

• --all-user-topics Reset tool to delete offsets for all topics related to available groups

Compatibility, Deprecation, and Migration Plan

...