Spring for Apache Kafka 1.0 Candidate 1 发布了，以下是本次发布值得关注的内容：
A ConsumerRebalanceListener can be injected into the MessageListenerContainer;
The KafkaConsumer and KafkaProducer can be customized with (De)Serializer s for key and value in the ConsumerFactory and ProducerFactory, respectively; this is an alternative to configuring using the properties.
JsonSerializer and JsonDeserializer s are provided, based on the Jackson library;
A RecordFilterStrategy and the FilteringMessageListenerAdapter are provided to allow skipping records or dealing with duplicate deliveries;
A self-explanatory RetryingMessageListenerAdapter is provided;
A ListenerContainerIdleEvent is emitted, after a configurable time, when the MessageListenerContainer has moved to an idle state;
TopicPartitionInitialOffset is provided to allow configuring the MessageListenerContainer to be assigned to specific partitions in the topic(s) and, optionally, seek to the desired offset when starting;
The @KafkaListener 's @TopicPartition attribute is enhanced with the @PartitionOffset property for initial offset configuration;
Improvements for consumer rebalance events.
软件详情：https://spring.io/blog/2016/06/07/spring-for-apache-kafka-1-0-release-candidate-1-available
下载地址：http://repo.spring.io/libs-release-local/org/springframework/spring/
来自:开源中国社区
