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@KafkaListenermethod) can now infer the type forpayloadconversion 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 theListenerto avoid clashing (re-routing) to the sametopicwith the samemessageKeywhen sending, e.g. with the Spring Integration Adapters.- More testing utilities. …