发布于 2017-10-03 00:25:06 | 152 次阅读 | 评论: 0 | 来源: 网友投递
Apache Kafka 开源消息系统
Apache Kafka是一个开源消息系统项目,由Scala写成。该项目的目标是为处理实时数据提供一个统一、高通量、低等待的平台。
Spring for Apache Kafka 2.0 GA 版已正式发布。可从 Release Repository 和 Maven Central 下载:
repositories { maven { url 'http://repo.spring.io/release' } } compile "org.springframework.kafka:spring-kafka:2.0.0.RELEASE"
如 2.0 RC1 发布说明中提到的,1.3 GA 也支持使用 Spring Framework 4.3.x 应用程序的 Kafka 0.11.x.x 客户端。
6 个月的开发工作主要是为 Spring for Apache Kafka 项目带去对 Java 8 和 Spring Framework 5 的支持:
Apache Kafka 0.11.x.x
client
Transactions support
Headers mapping
Kafka Streams support
KafkaAdmin
is now available to automatically add topics (for NewTopic
beans present in the application context)
errorHandler
and groupId
support for @KafkaListener
; also Consumer
argument resolution
@EmbeddedKafka
for testing support
此外,还有 spring-integration-kafka-2.3.0.RELEASE 的小版本更新,该版本使用 spring-kafka-1.3.0.RELEASE 基础,并提供一些功能来支持 Apache Kafka 0.11.x.x 客户端。