Getting metrics from KafkaReceiver

[gavvvr]

Hello

The io.github.nomisRev.kafka.publisher.KafkaPublisher interface in this library exposes metrics() function to get metrics from the underlying org.apache.kafka.clients.producer.KafkaProducer.
Unfortunately, the io.github.nomisRev.kafka.receiver.KafkaReceiver interface does not expose anything similar to obtain metrics.

This is a feature request to make it possible to obtain metrics from the underlying org.apache.kafka.clients.consumer.KafkaConsumer. As for now, I don't even see any workaround to get consumer metrics, because KafkaConsumer gets created on each receive() call and is very well encapsulated.

There are different extensions on org.apache.kafka.clients.consumer.*-types (including raw KafkaConsumer) in Consumer.kt and I could probably refactor current code to use them, but all of them are marked as deprecated with a recommendation to use io.github.nomisRev.kafka.receiver.KafkaReceiver instead.

I guess that receive() method on KafkaReceiver should rather return some advanced combined type, which has both traits: 1) the Flow itself + 2) other interfaces with additional capabilities (for example, for accessing metrics)

[Wrent]

Hi, I've ran into the same issue here that I am not able to easily obtain metrics from the KafkaConsumer. It may be possible to retrieve it directly from MBeanServer via clientId, but I haven't tried that yet.

Another option how to support this might be adding some equivalent to io.github.nomisRev.kafka.publisher.PublisherSettings.ProducerListener, which I currently use for accessing the metrics from the publisher.