Unable to pause Kafka consumer
I am working in java springboot, want to pause consumer for certain time period I am trying following code but looks like it is not working. Because when I debug code goes into 2nd if also. I am assuming when paused it shouldnt be in running state. Please guide me how can I manage this ?
Upgrading Apache Kafka client to 3.8.0 issue
after upgrading apache kafka client from 3.7.1 to 3.8.0 we ran into this UnsatisfiedLinkError during messages put on a topic:
Kafka Test – InvalidReceive Exception (size = 369296129 larger than 104857600)
I have only kafka consumer in my code, below is the configuration:
Spring-kafka retry issue when @KafkaListener’s autoStartup is false
In one of my applications I want to use non-blocking retries while manually starting the @KafkaListener
as described here.