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. 了解更多信息，可参看发布说明。 Spring for Apache Kafka 1.0 Candidate 1 发布下载地址
