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发布主页

下载地址


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

查看所有标签

猜你喜欢:

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

新内容创业:我这样打造爆款IP

新内容创业:我这样打造爆款IP

南立新、曲琳 / 机械工业出版社 / 2016-5-10 / 39.00

这是个内容创业爆棚的时代,在采访几十家内容创业公司,与一线最优秀的创业者独家对话之后,作者写作了这本书,其中包括对这个行业的真诚感触,以及希望沉淀下来的体系化思考。 本书共分三个部分讲述了爆红大号的内容创业模式和方法。其中第一部分,讲述了新的生产方式,即内容形态发展的现状--正在被塑造;第二部分,讲述了新的盈利探索,即从贩卖产品到贩卖内容的转变,该部分以多个案例进行佐证,内容翔实;第三部分,......一起来看看 《新内容创业:我这样打造爆款IP》 这本书的介绍吧!

CSS 压缩/解压工具
CSS 压缩/解压工具

在线压缩/解压 CSS 代码

Base64 编码/解码
Base64 编码/解码

Base64 编码/解码