THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
| Table of Contents |
|---|
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:
| 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
| Code Block | ||||||||
|---|---|---|---|---|---|---|---|---|
| /*
|
| option
*/
private static OptionSpecBuilder resetAllExternalTopicsOption;
private int maybeResetInputAndSeekToEndIntermediateTopicOffsets(final Map consumerConfig,
final boolean dryRun,
final boolean resetAllExternalTopics,
final List<MemberDescription> members)
Proposed Changes
...
| |
public class 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
Because it is an option addition Compatibility, Deprecation, and Migration Plan are not a problem
Rejected Alternatives
Not applicable.