Spring XD 1.1 M2 and 1.0.3 released---support kafka
2023-09-11 14:21:41 时间
官方地址: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
相关文章
- Spring Boot Kafka
- 淘东电商项目(49) -ELK+Kafka分布式日志收集(docker下搭建kafka)
- Is Spring Integration 5.5.10 must be based on Java 9 to use or depend on spring integration? #3761
- Spring Boot集成kafka完整版
- Spring源码之容器的功能扩展和refresh方法解析
- Spring源码之将Xml文件解析为Document对象(三)
- Spring为IOC容器注入Bean的五种方式
- 【kafka原理】Kafka生产者 (分区策略和ACK应答机制)
- kafka可视化客户端工具(Kafka Tool)的基本使用
- Quartz cron 表达式(linux 定时器,java 定时任务,spring task定时任务)
- kafka生产者性能监控:Monitor Kafka Producer for Performance
- Spring 声明式事务管理
- 【Spring】@Value注入配置文件 application.yml 中的值失败怎么办
- springMVC和spring各自扫描自己的注解不要相互混淆
- 2023年Spring MVC相关面试题
- Kafka报错——log问题导致ERROR Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.
- spring mvc Spring Data Redis RedisTemplate [转]
- Spring RestTemplate介绍
- spring cloud zipkin sleuth与spring boot aop结合后,启动慢
- Linux安装gssapi、kafka-python实现Kerberos认证连接Kafka等中间件集群服务(最新版)
- Spring Boot 2.X 自定义错误页面