Hello, we have been using the streams testing suite for some time now. We use
custom serializers/deserializers for our kafka data, and allow for some custom
configuration of the serdes via the ‘configure(Map)’ method.
Something we noticed is that for the TopologyTestDriver this is never called,
Hi Team,
we need some help regarding ca certificate authority change in kafka .
Currently we are connecting in kafka using ssl implementation.
kafka version used is 1.1.1
below is server.properties
listeners=INT://$PVT_HOST_NAME:9094,EXT://$PVT_HOST_NAME:9092
advertised.listeners=INT://$PVT_HO