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