...

Public Interfaces

StreamsResetter.class

/*

...

add reset-all-external-topics option

...

*/

...

private static OptionSpecBuilder resetAllExternalTopicsOption;

...

private int maybeResetInputAndSeekToEndIntermediateTopicOffsets(final Map

...

                                                                    final boolean dryRun,

                                                                    final boolean resetAllExternalTopics,

...

 consumerConfig,
																final boolean dryRun,
                                                                final boolean resetAllExternalTopics,
                                                                final List<MemberDescription> members)

Proposed Changes

We could add a config `--reset-all-external-topics` to the reset tool such that when enabled, we could delete offsets for all involved topics. The topic metadata could be acquired by issuing a `DescribeGroup` request from admin client, which is stored in the member subscription information.

...