The issue is a known problem reported here spring-projects/spring-kafka#1587 and also here spring-projects/spring-kafka#1587.
Essentially when working with transaction, the lag of the consumer group get messed up i.e. when a read_committed consumer consumes everything, the lag stay stuck at 1.
I wonder if Kafka4s does anything or has anything to handle that use case?
I'm asking, because while not completely sure, i have seen a code in the lib that i could not beging to understand until i red the above
Also in the process i would like to ask what is the difference if a method of the same name, seemingly having the same purpose in a package object slightly above
https://github.com/Banno/kafka4s/blob/48f23050fecf539506bec236aeb0c66d75fe782f/core/src/main/scala/com/banno/kafka/package.scala
The issue is a known problem reported here spring-projects/spring-kafka#1587 and also here spring-projects/spring-kafka#1587.
Essentially when working with transaction, the lag of the consumer group get messed up i.e. when a read_committed consumer consumes everything, the lag stay stuck at 1.
I wonder if Kafka4s does anything or has anything to handle that use case?
I'm asking, because while not completely sure, i have seen a code in the lib that i could not beging to understand until i red the above
kafka4s/core/src/main/scala/com/banno/kafka/consumer/ConsumerOps.scala
Line 41 in b5fac91
Also in the process i would like to ask what is the difference if a method of the same name, seemingly having the same purpose in a package object slightly above
https://github.com/Banno/kafka4s/blob/48f23050fecf539506bec236aeb0c66d75fe782f/core/src/main/scala/com/banno/kafka/package.scala