I want to use Kafka Streams to perform stateful aggregations. The use-case is that we are getting a stream of events, which we want to store until we get a specific event, at which point we will perfo...

I'm trying to create a Spring Kafka @KafkaListener which is both transactional (kafa and database) and uses retry. I am using Spring Boot. The documentation for error handlers says that When transact...

I am trying to understand how DeadLetterPublishingRecoverer works in case of batch consumer. Most of the examples in documentation I can see are that of single record consumers. I want to implement a ...

I wrote a Kafka Producer & Consumer some time ago, and now I need to add another consumer to the application, but I'm having issues with the configurations of it. config class 1 @Configuration @En...