我很高兴代表 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 开发处理器模块。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 的处理器模块
• 使用 RxJava 的处理器模块
• 基于改进的 Spring Kafka 库的 Kafka 消息总线和 Kafka 源改进
• 精细的安全 ACL，以支持谁可以创建或销毁流和作业

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

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