spring-kafka tutorials and guides

How to skip corrupt (non-serializable) messages in Spring Kafka Consumer?

Sep 15, 2022

java apache-kafka spring-kafka

Kafka Acknowledgment vs Kafka commit

Oct 18, 2022

apache-kafka kafka-consumer-api spring-kafka

How to use Spring-Kafka to read AVRO message with Confluent Schema registry?

Oct 26, 2022

avro spring-kafka confluent-platform confluent-schema-registry

How can I retry failure messages from kafka?

Oct 29, 2022

spring-boot apache-kafka spring-kafka

Spring Cloud Kafka Stream Unable to create Producer Config Error

Nov 23, 2020

spring-boot gradle kotlin spring-cloud-stream spring-kafka

Kafka broker node goes down with "Too many open files" error

Nov 14, 2022

apache-kafka centos spring-kafka ulimit lsof

Spring KafkaListener: How to know when it's ready

Aug 31, 2022

spring spring-boot apache-kafka spring-kafka spring-kafka-test

Spring Kafka JsonSerializer usage

Oct 16, 2022

java spring serialization apache-kafka spring-kafka

Tombstone messages not removing record from KTable state store?

May 07, 2021

apache-kafka-streams spring-cloud-stream spring-kafka

How to determine a Kafka consumer's offset

Nov 06, 2022

apache-kafka spring-kafka

spring kafka No type information in headers and no default type provided

Mar 20, 2022

spring-boot apache-kafka spring-kafka

Kafka in Kubernetes - Marking the coordinator dead for group

Aug 13, 2022

java apache-kafka kubernetes apache-zookeeper spring-kafka

How to pass dynamic topic name to @KafkaListener(topics) from environment variable

Nov 07, 2022

java spring-boot kafka-consumer-api spring-kafka spring-el

spring boot kafka LocalDateTime

Mar 08, 2022

java maven spring-boot spring-kafka

Kafka: The message when serialized is larger than the maximum request size you have configured with the max.request.size configuration

Nov 16, 2022

apache-kafka kafka-consumer-api kafka-producer-api spring-kafka

List Kafka Topics via Spring-Kafka

Feb 04, 2022

java apache-kafka kafka-consumer-api spring-kafka

How to write Unit test case for adding callback for ListenableFuture

Mar 04, 2022

unit-testing junit concurrency mockito spring-kafka

New posts in spring-kafka