Top "Spring-kafka" questions

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

Transaction Synchronization in Spring Kafka

I want to synchronize a kafka transaction with a repository transaction: @Transactional public void syncTransaction(){ myRepository.save(someObject) kafkaTemplate.send(…

spring-transactions spring-kafka
How to write Kafka consumers - single threaded vs multi threaded

I have written a single Kafka consumer (using Spring Kafka), that reads from a single topic and is a part …

java multithreading deployment apache-kafka spring-kafka
Apache Kafka: Replay messages in a topic

I'm considering using Apache Kafka as an event store for storing events within a microservice. One thing that I read …

apache-kafka spring-kafka
Handling exceptions in Kafka streams

Had gone through multiple posts but most of them are related handling Bad messages not about exception handling while processing …

java apache-kafka-streams spring-kafka
Can a single Spring's KafkaConsumer listener listens to multiple topic?

Anyone know if a single listener can listens to multiple topic like below? I know just "topic1" works, what if …

spring spring-boot spring-kafka
Kafka consumer exception and offset commits

I've been trying to do some POC work for Spring Kafka. Specifically, I wanted to experiment with what are the …

java spring apache-kafka kafka-consumer-api spring-kafka
Problems adding multiple KafkaListenerContainerFactories

Hi I'm currently dabbling in Spring Kafka and succeeded in adding a single KafkaListenerContainerFactory to my listener. Now I'd like …

spring spring-boot apache-kafka spring-kafka
The class is not in the trusted packages although appears in the list of trusted packages

I am trying to implement a simple Kafka communication between 2 different Spring Boot applications with out any special settings, this …

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

Sorry for the question being too generic, but someone has some tutorial or guide on how to perform producer and …

junit apache-kafka spring-cloud spring-kafka spring-cloud-stream
Spring boot spring.kafka.bootstrap-servers not getting picked up by consumer config

I'm trying to use connect a spring boot project to kafka . In my application.properties file I have the following …

spring-boot spring-kafka