智能化下的产物,无人棋牌室
Spring for Apache Kafka 1.0 Candidate 1 发布了,以下是本次发布值得关注的内容:
- A
ConsumerRebalanceListener
can be injected into theMessageListenerContainer
; - The
KafkaConsumer
andKafkaProducer
can be customized with(De)Serializer
s forkey
andvalue
in theConsumerFactory
andProducerFactory
, respectively; this is an alternative to configuring using the properties. JsonSerializer
andJsonDeserializer
s are provided, based on the Jackson library;- A
RecordFilterStrategy
and theFilteringMessageListenerAdapter
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 theMessageListenerContainer
has moved to an idle state; TopicPartitionInitialOffset
is provided to allow configuring theMessageListenerContainer
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.
了解更多信息,可参看发布说明。