The Spring Integration for Apache Kafka extension project provides inbound and outbound channel adapters and gateways for Apache Kafka. Apache Kafka is a distributed publish-subscribe messaging system that is designed for high throughput (terabytes of data) and low latency (milliseconds). For more information on Kafka and its design goals, see the Apache Kafka main page.
Note
|
Starting with Spring Integration 5.4.0, this project has been absorbed by the core one under respective spring-integration-kafka module.
This repository is archived and remain in read-only mode for informational purpose.
|
Starting from version 2.0 version this project is a complete rewrite based on the new
spring-kafka project which uses the pure java "new" Producer
and
Consumer
clients provided by Kafka.
See the Spring Integration kafka Sample for a simple Spring Boot application that sends and receives messages.
In order to build the project:
./gradlew build
In order to install this into your local maven cache:
./gradlew install
Documentation for this extension is contained in a chapter of the Spring Integration Reference Manual
Producer record metadata for sends performed on the outbound channel adapter are now sent only to the successChannel
.
With earlier versions, it was sent to the outputChannel
if no successChannel
was provided.
Pull requests are welcome. Please see the contributor guidelines for details.