Table of Contents |
---|
Status
Current state: Under DiscussionAccepted
Discussion thread: here
JIRA: here
...
of DefaultKafkaClientSupplier
.
We will also add a new public method in StreamsConfig
called getKafkaClientSupplier
. It will return KafkaClientSupplier
based on the config.
Proposed Changes
In KafkaStreams
constructor, we will read the value of default.client.supplier
from StreamsConfig
. We will use reflection to create an object of given class and throw
...