Spring For Apache Kafka 2.0 Milestone 1 发布

内容简介：Spring For Apache Kafka 2.0 Milestone 1 发布

Spring for Apache Kafka 2.0 的首个里程碑版本发布了 — Spring For Apache Kafka 2.0.0.M1 。

Spring for Apache Kafka 用于为 Apache Kafka 提供熟悉的 Spring 抽象。

2.0 系列中的重要新功能包括：

• 在 KafkaTemplate 中支持时间戳

• Seek to beginning/end of topics

• New threading model facilitated by KIP-62 - now that the consumer client does not rely on  poll() being called frequently, the threading model is much simpler; avoiding the need for internal  pause() /  resume() processing. Listeners are now always invoked on the consumer thread. This, in turn, has facilitated:

• ConsumerAwareMessageListener (and  BatchConsumerAwareMessageListener ) are provided so that listener implementations can access the  Consumer<?, ?> object to perform operations such as  pause() ,  resume() ,  metrics() etc.

• @KafkaListener POJO methods can now be annotated with  @SendTo to send the method result to some other topic.

@KafkaListener(id = "replyingListener", topics = "inTopic")
@SendTo("replyTopic")
public String replyingListener(String in) {
	return in.toUpperCase();
}

要了解更多信息，查看 Forwarding Listener Results using @SendTo 或 发布主页

下载地址

以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，也希望大家多多支持 码农网

查看所有标签

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。