Spring For Apache Kafka 2.0 Milestone 1 发布

栏目: 服务器 · Apache · 发布时间: 8年前

内容简介: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发布主页

下载地址


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

查看所有标签

猜你喜欢:

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

网络江湖三十六计

网络江湖三十六计

程苓峰,王晶 / 经济日报出版社 / 2009-6 / 40.00元

《网络江湖三十六计》内容简介:貌合神离:卖个破绽给对手,让他尝到甜头,自认为可安枕无忧,往往就松懈大意。于是,自己蓄力并反击的机会就来了。诱敌就是“貌合”,暗地发力就是“神离”。一起来看看 《网络江湖三十六计》 这本书的介绍吧!

JSON 在线解析
JSON 在线解析

在线 JSON 格式化工具

在线进制转换器
在线进制转换器

各进制数互转换器

随机密码生成器
随机密码生成器

多种字符组合密码