This Confluence has been LDAP enabled, if you are an ASF Committer, please use your LDAP Credentials to login. Any problems file an INFRA jira ticket please.

Child pages
  • KIP 157 - Add consumer config options to streams reset tool
Skip to end of metadata
Go to start of metadata



Current state: Accepted

Discussion thread: here 

JIRA: here 

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


The StreamsResetter doesn't let the user pass in any configurations to the embedded consumer. This is a problem in secure environments because you can't configure the embedded consumer and Admin Client to talk to the cluster. The streams reset tool should allow an approach to pass consumer configurations.

Public Interfaces

To add an option to StreamsReset tool.

 commandConfigOption = optionParser.accepts("command-config", "Property file containing configs to be passed to Admin Client and Embedded Consumer")
              .describedAs("command config property file"); 

Proposed Changes

To add an options to streams reset tool.

  1. command-config To pass consumer configuration properties file.

Compatibility, Deprecation, and Migration Plan

    • This is purely an addition of an option to It will not cause any compatibility issues.

Rejected Alternatives

No rejected alternatives. As without the config options, streams reset tool will not work in Secure Kafka cluster

  • No labels