losing kafka messages due to exceptions in consumer code...

How to use EntityManager/Hibernate Transaction with @KafkaHandler...

Is Spring Kafka KafkaListener annotation able to take config property as topic name?...

Problem with start of @KafkaListener (Spring)...

Spring Kafka - "ErrorHandler threw an exception" and lost some records...

How to AutoCreate Kafka Topic according to incoming topic pattern through kafkalistener service in s...

Kafka - CommitFailedException - No timeout poll(max.poll.interval.ms)...

Spring Kafka. Non-blocking retries - topics are created even when autoCreateTopics property is false...

Spring cloud stream Kafka creates a weird topic on startup...

How to deserialize message in consumer when produced message is a model type which consumer has no r...

Spring Boot Kafka, package name in the message header...

Spring cloud Kafka multiple Brokers with SSL...

spring cloud stream kafka: : Error creating bean with name 'supplierInitializer' defined in ...

Spring Boot | spring EL using with annotation attribute value to set any random value using properti...

How can I create many kafka topics during spring-boot application start up?...

Handling exception in Spring Kafka...

How to configure Spring Boot Kafka client so it does not try to connect...

Spring Kafka Template - Connect to Kafka Topic on Spring Boot Startup...

Configure to start new span in KafkaMessageListenerContainer not on listener (Kafka + Sleuth)...

Spring Boot + Kafka handle if Kafka is not available...

Pass array list of topic names to @KafkaListener...

Is there a way to send messages to topic only when received from external system?...

stream-client Global thread has died on Spring Boot application shutdown...

kafka streams stop working after upgrade to spring-kafka:2.5.3.RELEASE...

Out-of-the-box capabilities for Spring-Kafka consumer to avoid duplicate message processing...

Can't connect to my kafka running on docker from spring boot application running via intellij...

KafkaEmbedded throwing ClassNotFoundException for SecurityProtocol...

Passing Acknowledgment to a spring KafkaListener consumer method...

Missing bean 'zipkin2.reporter.Sender' when using `@AutoConfigureAfter(TraceAutoConfiguratio...

Trigger rebalance of a consumer group...