Relative Content

Tag Archive for javaspring-bootspring-kafka

Spring kafka AckMode RECORD VS MANUAL_IIMEDIATE

In our usecase, we are supposed to acknowledge every kafka message/record as soon as it is processed successfully by KafkaListener. I think that this can be achieved using AckMode.RECORD as well as AckMode.MANUAL_IMMEDIATE (as long as we ack on the same listener thread, which we are).

Replace DLQ response of kafka

I’m trying to convert the error message from a lister to not send the msg to DLQ, but my return topic with some minimum information. How can I do that?

Spring Boot: Using SSL Bundles for spring-kaka MATLS

After raising an issue on spring-boot (https://github.com/spring-projects/spring-boot/issues/40398) and some discussion with the team, it seems like it should be possible to use SSL bundles on the KafkaTemplate the same as is documented for the RestTemplate.