Top "Spring-kafka" questions

The Spring for Apache Kafka (spring-kafka) project applies core Spring concepts to the development of Kafka-based messaging solutions.

Dead letter queue (DLQ) for Kafka with spring-kafka

What is the best way to implement Dead letter queue (DLQ) concept in Spring Boot 2.0 application using spring-kafka 2.1.x to …

spring-boot apache-kafka spring-integration spring-kafka dead-letter
Spring Kafka: Multiple Listeners for different objects within an ApplicationContext

Can I please check with the community what is the best way to listen to multiple topics, with each topic …

java apache-kafka spring-kafka
spring kafka No type information in headers and no default type provided

I've got a spring boot app that defines: a REST Controller that writes to a kafka topic, STREAM_TOPIC_IN_…

spring-boot apache-kafka spring-kafka
Spring Kafka - How to reset offset to latest with a group id?

I am currently using Spring Integration Kafka to make real-time statistics. Though, the group name makes Kafka search all the …

java spring apache-kafka spring-integration spring-kafka
Testing a @KafkaListener using Spring Embedded Kafka

I am trying to write a unit test for a Kafka listener that I am developing using Spring Boot 2.x. …

java spring-boot apache-kafka spring-kafka spring-boot-test
How to get message by key from kafka topic

I try to get message by key from kafka. I found the only one solution is to use StateStore but …

java apache-kafka spring-kafka
Spring Kafka Producer not sending to Kafka 1.0.0 (Magic v1 does not support record headers)

I am using this docker-compose setup for setting up Kafka locally: https://github.com/wurstmeister/kafka-docker/ docker-compose up works fine, …

spring spring-boot apache-kafka docker-compose spring-kafka
Spring Kafka Consumer Retry

I am using Spring Kafka consumer which fetches messages from a topic and persist them into a db. If a …

spring-boot apache-kafka kafka-consumer-api spring-kafka
Kafka: The message when serialized is larger than the maximum request size you have configured with the max.request.size configuration

Getting the following error (Kafka 2.1.0): 2018-12-03 21:22:37.873 ERROR 37645 --- [nio-8080-exec-1] o.s.k.support.LoggingProducerListener : Exception thrown when sending …

apache-kafka kafka-consumer-api kafka-producer-api spring-kafka
java.lang.NoSuchMethodError on Kafka Consumer with spring-kafka 2.1.0 and SpringBoot 1.5.9

I am trying to setup Kafka Consumer using SpringBoot(1.5.9) and Spring-kafka(2.1.0). However when I start my app I get java.…

spring-kafka