Spring XD 1.1 M2 and 1.0.3 released---support kafka
官方地址:http://spring.io/blog/2014/12/23/spring-xd-1-1-m2-and-1-0-3-released
On behalf of the Spring XD team, I am very pleased to announce the second milestone release of Spring XD 1.1 and the 1.0.3 maintenance release.
Download Links:
* 1.1.0.M2 RELEASE: zip, 1.0.3.RELEASE: zip
The 1.1 M2 release includes bug fixes and enhancements as well as several new features:
- Kafka based Message Bus. If Kafka is your middleware du jour, you will feel right at home.
- Batching and compression support for RabbitMQ provides significantly increased effective message rate throughput.
- Develop Processor modules using Project Reactor’s Stream API. The Stream API is based on the Reactive Streams specification that provides a standard for asynchronous stream processing with non-blocking backpressure. This allows you to use a functional programming model as the basis for processing event streams. Combined with XD’s support for Data Partitioning on the Message Bus, you can create very powerful distributed stream processing solutions.
- Easily develop, test, and package custom modules. A parent pom bootstraps all the dependencies required for building a custom module and bundles your module and dependencies into a single uberjar file. There is also support for integration testing your module with JUnit using an embedded single node server.
- Upload custom modules to the admin server over HTTP.
- Role based authorization of REST endpoints give you control over “who can do what”.
- File based authentication as a simple alternative to LDAP.
- Sqoop Batch job integration
Please see the reactor-moving-average project for an example of using Reactor’s Stream API and the si-dsl-module for a complete example of developing a custom module.
Of note for the next release of Spring XD 1.1 RC1 we will be including support for
- Processor modules that use Spark Streaming
- Processor modules that use RxJava
- Kafka Message Bus and Kafka source improvements based on a revamped Spring Kafka Library
- Granular security ACLs to support who can create or destroy streams and jobs
Feedback is very important, so please get in touch with questions and comments via
- StackOverflow
spring-xd
tag - Spring JIRA or GitHub Issues
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。