THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Public Interfaces
StreamsResetter.class
/* add reset-all-external-topics option */
Code Block | ||||
---|---|---|---|---|
| ||||
private static OptionSpecBuilder resetAllExternalTopicsOption; private int maybeResetInputAndSeekToEndIntermediateTopicOffsets(final Map consumerConfig, final boolean dryRun, final boolean resetAllExternalTopics, final List<MemberDescription> members) |
...