Description
The StreamsConfig doesn't currently pass custom configs defined by the user to the ConsumerConfig and ProducerConfig.
i.e.,
consumer.interceptor.classes=com.app.kafka.StatsdConsumerInterceptor
will currently be dropped.
Attachments
Issue Links
- links to