Status

Current state: Discussion 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 secured 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 approch approach to pass consumer configurations. There are 2 options.

Public Interfaces

To add 2 options to an option to StreamsReset tool.

consumerPropertyOption commandConfigOption = optionParser.accepts("consumercommand-propertyconfig", "AProperty mechanismfile tocontaining passconfigs user-definedto propertiesbe inpassed theto formAdmin key=valueClient toand theEmbedded consumerConsumer")
        .withRequiredArg()
        .ofTypewithRequiredArg(String.class)
        .describedAs("consumer property");
 
consumerConfigOption = optionParser.accepts("consumer.config", "Consumer configuration properties file, Note that " + consumerPropertyOption.toString() + " takes precedence over this config")
        .withRequiredArg(.ofType(String.class)
        .ofType(String.class)
        .describedAs("Consumercommand config property file");
  

Proposed Changes

To add 2 an options to streams reset tool.

1. consumer.command-config - To pass consumer configuration properties file.consumer-property - To pass consumer property as key=value pair

Compatibility, Deprecation, and Migration Plan

...

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