You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 11 Next »

Status

Current stateUnder Discussion

Discussion thread: https://lists.apache.org/thread.html/r1d7fb7b75a4523007d0768aed056b08ad18046b604480d219a31ebe2%40%3Cdev.kafka.apache.org%3E

JIRA: Unable to render Jira issues macro, execution error.

Motivation

As of today, user has to specify `--input-topic` in the stream reset to be able to reset offset to a specific position. For a stream job with multiple external topics that needs to be purged, users usually don't want to name all the topics in order to reset the offsets. It's really painful to look through the entire topology to make sure we purge all the committed offsets.

So we want to reset all related topics with one option.

Public Interfaces

StreamsResetter.class

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

add reset-all-external-topics option
private static OptionSpecBuilder resetAllExternalTopicsOption;


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.

  •  Added '--reset-all-external-topics' option

Compatibility, Deprecation, and Migration Plan

  • Because it is an option addition Compatibility, Deprecation, and Migration Plan are not a problem

Rejected Alternatives

Not applicable.

  • No labels