发布于 2017-04-27 20:20:32 | 130 次阅读 | 评论: 0 | 来源: 网友投递
Spring Framework 开源j2ee框架
Spring是什么呢?首先它是一个开源的项目,而且目前非常活跃;它是一个基于IOC和AOP的构架多层j2ee系统的框架,但它不强迫你必须在每一层 中必须使用Spring,因为它模块化的很好,允许你根据自己的需要选择使用它的某一个模块;它实现了很优雅的MVC,对不同的数据访问技术提供了统一的接口,采用IOC使得可以很容易的实现bean的装配,提供了简洁的AOP并据此实现Transcation Managment,等等
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 或发布主页
下载地址