Closed malafeev closed 7 years ago
I think with Kafka Streams you can provide a KafkaClientSupplier
so you can return your TrackingKafkaConsumer and TrackingKafkaProducer instead of the original one. Another option that I think could be useful is to use ConsumerInterceptor
and ProducerInterceptor
, that way you can add or remove the tracing at the KafkaStreams configuration level.
thank you @nachomdo I will try
but looks like there is no way to intercept processing of records.
I cannot find a way to instrument kafka streams.