Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Current stateUnder Discussion vote

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

JIRA:

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9042

...

  • 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

  • Extend input to add the ability to reset multiple inputs simultaneously

...

Public Interfaces

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


Code Block
languagejava
titleadd reset-all-external-topics option
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

...