Ai大模型相关案例,AI
Spring for Apache Kafka 1.0 Candidate 1 发布了,以下是本次发布值得关注的内容:
- A
ConsumerRebalanceListenercan be injected into theMessageListenerContainer; - The
KafkaConsumerandKafkaProducercan be customized with(De)Serializers forkeyandvaluein theConsumerFactoryandProducerFactory, respectively; this is an alternative to configuring using the properties. JsonSerializerandJsonDeserializers are provided, based on the Jackson library;- A
RecordFilterStrategyand theFilteringMessageListenerAdapterare provided to allow skipping records or dealing with duplicate deliveries; - A self-explanatory
RetryingMessageListenerAdapteris provided; - A
ListenerContainerIdleEventis emitted, after a configurable time, when theMessageListenerContainerhas moved to an idle state; TopicPartitionInitialOffsetis provided to allow configuring theMessageListenerContainerto be assigned to specific partitions in the topic(s) and, optionally, seek to the desired offset when starting;- The
@KafkaListener‘s@TopicPartitionattribute is enhanced with the@PartitionOffsetproperty for initial offset configuration; - Improvements for consumer rebalance events.
了解更多信息,可参看发布说明。









