THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Current state: Under Discussion vote
Discussion thread: https://lists.apache.org/thread.html/r1d7fb7b75a4523007d0768aed056b08ad18046b604480d219a31ebe2%40%3Cdevr2dc1cabfb75df6117bc464c29f0700dd1214fd1352bacfa99381b9bf%40%3Cdev.kafka.apache.org%3E
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
- Extend input to add the ability to reset multiple inputs simultaneously
Public Interfaces
So we want to reset all related topics with one option.
Public Interfaces
StreamsResetter.class
...
Code Block | ||||
---|---|---|---|---|
| ||||
private static OptionSpecBuilder resetAllExternalTopicsOption; |
...