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

秒客网