spring-kafka Examples and Free Source Code

How to wrap a @KafkaListener which is handled by seekToCurrentErrorHandler with a latch for testing...

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

Why I lost messages when using kafka with EOS Beta...

apache-kafka spring-kafka

available: expected at least 1 bean which qualifies as autowire candidate...

java spring spring-boot apache-kafka spring-kafka

Exception while testing Spring Kafka error handler for @KafkaListener...

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

when to use RecoveryCallback vs KafkaListenerErrorHandler...

spring-kafka

Getting java.lang.ClassCastException when deploying my batch consumer using spring-kafka...

spring-kafka

Apache Kafka - REST API based consumer?...

java spring-boot apache-kafka spring-kafka

Spring 5.X web Kafka Integeration using xml configuration (Not Spring boot)...

spring-integration spring-kafka

Spring Kafka: C++ producer of reply for ReplyingKafkaTemplate...

c++spring apache-kafka spring-kafka librdkafka

Kafka ConcurrentMessageListenerContainer stops consuming abruptly...

apache-kafka spring-kafka

Consumer application causing duplicate while reading records from multiple partition...

apache-kafka spring-kafka

MessageConversionException during serialization in spring-kafka?...

java spring apache-kafka spring-kafka

add kafka autoStartUp false in the ConsumerConfig...

spring-boot spring-kafka

NoClassDefFoundError: scala/math/Ordering with spring-kafka-test 2.5.7...

java spring scala spring-kafka

Requeue the failed record in the kafka topic...

spring-kafka

Making Kafka ConcurrentMessageListenerContainer Work as a Batch...

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

What value to provide for the Kafka schema.registry.ssl.engine.factory.class...

java spring-boot spring-kafka confluent-schema-registry embedded-kafka

@KafkaListener and one single Consumer...

apache-kafka kafka-consumer-api spring-kafka

Can I use KafkaTemplate with singleton scope?...

spring spring-boot spring-kafka

How to use avro native decoder when using a PollableMessageSource input in spring cloud stream?...

java avro spring-kafka spring-cloud-stream confluent-schema-registry

Remote Kafka Consumer...

spring-boot apache-kafka spring-kafka apache-kafka-connect kafka-cluster

Multiple StreamListeners to same Topic with Spring Cloud Stream connected to Kafka...

apache-kafka spring-kafka spring-cloud-stream

Spring Kafka with Avro Deserializer...

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

Spring cloud stream kafka transactions in producer side...

spring-kafka spring-cloud-stream

How to create unit test with kafka embedded in the spring cloud stream...

junit apache-kafka spring-cloud spring-kafka spring-cloud-stream

spring-kafka error handler invoked too many times...

spring spring-boot apache-kafka spring-kafka

spring-cloud-stream - Kafka producer prefix unique per node...

spring-boot apache-kafka spring-kafka spring-cloud-stream

How to add Micrometer Timer in KafkaListener class, created by KafkaListenerContainerFactory?...

spring-boot spring-kafka micrometer spring-micrometer

What happens to a Kafka consumer group when all consumers are removed...

spring spring-boot apache-kafka kafka-consumer-api spring-kafka

Spring Boot Kafka Multiple Consumers with different properties configuration using appication.yml/pr...

spring spring-boot apache-kafka spring-kafka