Spring for Apache Kafka 1.0 Milestone 2 Available
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 returnListenableFuture<SendResult<K, V>>
to track publishing to the Kafka topic asynchronously.
- The
MessagingMessageListenerAdapter
(for@KafkaListener
method) can now infer the type forpayload
conversion from the method arguments. - A
StringJsonMessageConverter
, which can use the type inference to build the target object from JSON content using the JacksonObjectMapper
. RECEIVED_
headers have been added from theListener
to avoid clashing (re-routing) to the sametopic
with the samemessageKey
when sending, e.g. with the Spring Integration Adapters.- More testing utilities. …