Status

Current state: Accepted

Discussion thread: here 

Voting thread: here 

JIRA: here 

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

Motivation

To add an option dry-run in streams reset tool. This option provides information to users to display the actions which will be performed like what topics will be deleted/modified and for which all topic reset of offsets will happen. This option provides a clear information to the user about what all actions will be performed, it will not perform any actions. 

Public Interfaces

For streams reset tool, to add a new option dry-run.

dryRunOption = optionParser.accepts("dry-run", "Option to indicate to run streams reset tool to display actions it will perform"); 

 

Proposed Changes

Kafka Streams reset tool will have new option dry-run. After adding this option, when used with dry-run output looks as below.

bin/kafka-streams-application-reset.sh  --application-id streams-wordcount --input-topics streams-file-input,streams1 --dry-run

----Dry run to display the actions which will be performed when running Streams Reset Tool----
Following input topics offsets will be reset to beginning (for consumer group streams-wordcount) 
Topic - streams-file-input
Following internal topics offsets will be reset to beginning (for consumer group streams-wordcount)
Topic - streams-wordcount-Counts-repartition
Topic - streams-wordcount-Counts-changelog
Following internal topics will be deleted
Topic - streams-wordcount-Counts-repartition
Topic - streams-wordcount-Counts-changelog
Following input topics are not found, will skip them
Topic – streams1

 

Compatibility, Deprecation, and Migration Plan

    • This is purely an addition of an option to kafka-streams-application-reset.sh. It will not cause any compatibility issues.

Rejected Alternatives

As it is adding a new option, and providing information to the user before performing actual actions. With out this option, the user can know what is happening from the description of streams reset tool description.

  • No labels