The Spring for Apache Kafka (spring-kafka) project applies core Spring concepts to the development of Kafka-based messaging solutions.
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-letterCan I please check with the community what is the best way to listen to multiple topics, with each topic …
java apache-kafka spring-kafkaI'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-kafkaI 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-kafkaI 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-testI try to get message by key from kafka. I found the only one solution is to use StateStore but …
java apache-kafka spring-kafkaI 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-kafkaI 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-kafkaGetting 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-kafkaI 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