What happens when one consumer thread in ConcurrentKafkaListenerContainerFactory fails...

How to fix 'Failed to update metadata after xxx ms' in spring-kafka when send record in call...

Spring Kafka Stop container on Exception...

Chance of callback not getting registered for springkafka-template send method...

Kafka Listeners are getting active before spring boot application startup for Spring Kafka 2.2.3.REL...

How to run more than 1 application instances of ktable-ktable joins kafka streams application on sin...

Kafka listener receiving List<ConsumerRecord<String, String>>, is it possible to consume...

Update spring-kafka-test to 2.2.x but still use old kafka-client 1.1.1 with junit5 and spring boot 2...

When using @KafkaListener can I get a reference to the underlying KafkaConsumer as I want to read th...

How to parallelize Kafka message consumption...

Question about using the @KafkaListener autoStartup = "false" for multiple topics...

Kafka broadcast. How to know read offsets for consumer group if the only consumer in the group goes ...

Spring Kafka thread naming convention...

Spring-Kafka : Issue while deserialising kafka message - class not in a "trusted package"?...

Kafka Streams - Consumer memory overload...

Kafka Template: Timeout Exception while sending the message by kafka template...

KStream send record to multiple streams (not Branch)...

Spring Kafka Listener on Http Request...

Sending using KafkaTemplate<String, String> returns a exception for using String as a key...

How to commit offset with ConsumerAwareErrorHandler when using concurrency?...

Spring Cloud Stream Kafka - Serde class not found: org.apache.kafka.common.serialization.Serde$Strin...

spring-kafka listener shutdown...

spring-integration-kafka: Annotation-driven handling of KafkaProducerMessageHandler result?...

How to aggregate data hourly?...

Spring-Kafka with transactions, multiple threads...

Spring kafka error Caused by: java.lang.ClassNotFoundException: org.springframework.kafka.transactio...

Kafka Spring: How to write unit tests for ConcurrentKafkaListenerContainerFactory and ConcurrentMess...

KafkaListener annotation at class level with errorhandler property ignored...

How to seek Offset for Time Stamp with Spring for Kafka...

Spring kafka transaction id is wrong at start?...