I am pleased to announce that the spring-kafka (Spring for Apache Kafka) Second Milestone for version 1.0 is now available.

The artifacts org.springframework.kafka:spring-kafka:1.0.0.M2 and org.springframework.kafka:spring-kafka-test:1.0.0.M2 are available in the Milestone repository.

Changes since the First Milestone include:

• KafkaTemplate.send() methods now return ListenableFuture<SendResult<K, V>>

to track publishing to the Kafka topic asynchronously.

• The MessagingMessageListenerAdapter (for @KafkaListener method) can now infer the type for payload conversion from the method arguments.
• A StringJsonMessageConverter, which can use the type inference to build the target object from JSON content using the Jackson ObjectMapper.
• RECEIVED_ headers have been added from the Listener to avoid clashing (re-routing) to the same topic with the same messageKey when sending, e.g. with the Spring Integration Adapters.
• More testing utilities.

See also the Reference Manual for more information.

Spring Integration Kafka Support

Don't miss the First Milestone for Spring Integration Kafka 2.0 which is fully based on this Spring for Apache Kafka foundation.

Next Steps

• The Spring Boot Kafka starter and AutoConfiguration is in progress.
• A new Binder implementation for spring-cloud-stream.
• Flesh out the documentation, set up a project page etc.

Also we looking into the version 1.1 already to implement the interaction with Kafka using Reactive Streams with Reactor's Flux and Mono abstractions. At the same time the Apache Kafka 0.10.0 with its Kafka Streams feature, which would also be good addition into Spring for Apache Kafka 1.1, too.

Meanwhile we look forward to your feedback and if all goes well plan to release 1.0.0.RELEASE in the next few weeks!

Project Page | Documentation | Help