我谨代表 Spring XD 团队，非常高兴地宣布 Spring XD 1.1 的第二个里程碑版本和 1.0.3 的维护版本。

下载链接

• 1.1.0.M2 RELEASE: zip, 1.0.3.RELEASE: zip

1.1 M2 版本包括错误修复和增强功能以及几个新功能

• 基于 Kafka 的消息总线。如果您认为 Kafka 是您当前的中间件，那么您会感到宾至如归。
• RabbitMQ 的批处理和压缩支持提供了显著提高的消息速率吞吐量。
• 使用 Project Reactor 的 Stream API 开发 Processor 模块。 Stream API 基于 Reactive Streams 规范，该规范提供了一个用于处理具有非阻塞反压的异步流的标准。这允许您使用函数式编程模型作为处理事件流的基础。结合 XD 对 消息总线上的数据分区 的支持，您可以创建非常强大的分布式流处理解决方案。
• 轻松开发、测试和打包自定义模块。父 POM 引导构建自定义模块所需的所有依赖项，并将您的模块和依赖项打包到一个 uberjar 文件中。还支持使用 JUnit 和嵌入式单节点服务器 集成测试您的模块。
• 通过 HTTP 将自定义模块 上传到管理服务器。
• 基于角色的 REST 端点 授权 让您控制“谁可以做什么”。
• 作为 LDAP 的简单替代方案，提供 基于文件的身份验证。
• Sqoop 批处理作业集成

有关使用 Reactor 的 Stream API 的示例，请参阅 reactor-moving-average 项目，有关开发自定义模块的完整示例，请参阅 si-dsl-module。

值得注意的是，在 Spring XD 1.1 RC1 的下一个版本中，我们将包含对以下内容的支持：

• 使用 Spark Streaming 的 Processor 模块
• 使用 RxJava 的 Processor 模块
• 基于改进的 Spring Kafka 库，Kafka 消息总线和 Kafka 源得到了改进
• 细粒度的安全 ACLs，用于支持谁可以创建或销毁流和作业

反馈非常重要，因此请通过以下方式联系我们以获取问题和评论：

• StackOverflow spring-xd 标签
• Spring JIRA 或 GitHub Issues