I am pleased to announce that the
spring-kafka (Spring for Apache Kafka) Second Milestone for version
1.0 is now available.
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
to track publishing to the Kafka topic asynchronously.
@KafkaListenermethod) can now infer the type for
payloadconversion from the method arguments.
StringJsonMessageConverter, which can use the type inference to build the target object from JSON content using the Jackson
RECEIVED_headers have been added from the
Listenerto avoid clashing (re-routing) to the same
topicwith the same
messageKeywhen sending, e.g. with the Spring Integration Adapters.
- More testing utilities.
See also the Reference Manual for more information.
Don’t miss the First Milestone for Spring Integration Kafka 2.0 which is fully based on this Spring for Apache Kafka foundation.
- 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
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!