Status

Current state: Discussion

Discussion thread: here 

...

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

Motivation

The StreamsResetter doesn't let the user pass in any configurations to the embedded consumer. This is a problem in secured environments because you can't configure the embedded consumer to talk to the cluster. The streams reset tool should allow an approch to pass consumer configurations. There are 2 options.

...

consumerPropertyOption = optionParser.accepts("consumer-property", "A mechanism to pass user-defined properties in the form key=value to the consumer")
        .withRequiredArg()
        .ofType(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)
        .describedAs("Consumer config property file");
 

Proposed Changes

To add 2 options to streams reset tool.

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

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

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