Support currentLag() in doOnConsumer
gzahl opened this issue · 1 comments
gzahl commented
I wanted to use "consumer.currentLag(..)" with doOnConsumer and was just preparing a merge request, when i noticed that reactor-kafka is still using a 2.8 kafka-client.
Is there a rationale for this? Could we update it?
Can we still extend the ConsumerHandler to allow using "currentLag"? That would be very usefull.
Thanks!
garyrussell commented
Yes, it can be upgraded, but other changes might be required and we would likely need to use reflection to maintain backwards compatibility. Unless we go to a new version (1.4 or 2.0).
Contributions are welcome.