Versions Compared


  • This line was added.
  • This line was removed.
  • Formatting was changed.


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