Top "Spring-kafka" questions

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

Kafka producer JSON serialization

I'm trying to use Spring Cloud Stream to integrate with Kafka. The message being written is a Java POJO and …

spring apache-kafka spring-cloud-stream spring-kafka
EmbeddedKafka how to check received messages in unit test

I created a spring boot application that sends messages to a Kafka topic. I am using spring spring-integration-kafka: A KafkaProducerMessageHandler&…

spring junit apache-kafka spring-kafka
Spring Kafka Auto Commit Offset In Case of Failures

I am using Spring Kafka 1.2.2.RELEASE. I have a Kafka Listener as consumer that listens to a topic and index …

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

How to use Spring-Kafka to read AVRO message with Confluent Schema registry? Is there any sample? I can't find it …

avro spring-kafka confluent-platform confluent-schema-registry
Managing Kafka Topic with spring

We are planning to use Kafka for queueing in our application. I have some bit of experience in RabbitMQ and …

java spring-boot apache-kafka rabbitmq spring-kafka
How to skip corrupt (non-serializable) messages in Spring Kafka Consumer?

This question is for Spring Kafka, related to Apache Kafka with High Level Consumer: Skip corrupted messages Is there a …

java apache-kafka spring-kafka