Versions Compared

Key

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

...

Public Interfaces

StreamsResetter.class

/* add reset-all-external-topics option */

Code Block
languagejava
titleNothingSerdeadd 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)

...