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:

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

时间: 2024-10-21 22:13:29

Spring XD 1.1 M2 and 1.0.3 released---support kafka的相关文章

Spring XD简介:大数据应用的运行时环境

简介 Spring XD(eXtreme Data,极限数据)是Pivotal的大数据产品.它结合了Spring Boot和Grails,组成Spring IO平台的执行部分.尽管Spring XD利用了大量现存的Spring项目,但它是一种运行时环境,而不是一个类库或者框架,它包含带有服务器的bin目录,你可以通过命令行启动并与之交互.运行时可以运行在开发机上.客户端自己的服务器上.AWS EC2上或者Cloud Foundry上. Spring XD中的关键组件是管理和容器服务器(Admin

spring XD结合RabbitMQ方法介绍

1,Rabbitmq工作流程 消息生产者(即下图中的ClientA,ClientB)生产message并交给交换机Exchange,Exchange将消息按照RoutingKey分发到相应的队列Queue中,而我们的消费者(即下图中的Client1,Client2,Client3)需要做的事情就是监听队列Queue的事件,当有新的message到达的时候,做出相应的处理. Rabbitmq结构图: 2,Exchange交换类型介绍 具体来说,Exchange也有几个类型,完全根据key进行投递的

DocOptimizer 0.9.0 Beta Released

DocOptimizer 是一个文档优化工具,它通过移除Excel中多余的单元格:将嵌入的OLE替换成图片:移除文档中的隐藏信息:优化文档中的图片等等手段,将Office或PDF文件压缩20%-90%. 压缩过的文件和源文件看起来完全一样,Word还是Word,PPT还是PPT, 只是文件大小从几M,几十M,变成了几K. Features: [可选]移除冗余信息,比如多余的Excel单元格等. [可选]无损压缩图片,并移除多余像素. [可选]移文档中的隐藏信息,例如Comments,Docume

解决 VM with version 2.1.0 has multidex support ; VM has multidex support, MultiDex support library is disabled.问题

发布打包完之后,android studio提示 VM with version 2.1.0 has multidex support I/MultiDex: installI/MultiDex: VM has multidex support, MultiDex support library is disabled. 解决方案:更新gradle 版本为2.1.0.

Nagios 4.0.1 Released – Install on RHEL/CentOS 6.x/5.x and Fedora 19/18/17

http://www.tecmint.com/install-nagios-in-linux/ Nagios 4.0.1 Released – Install on RHEL/CentOS 6.x/5.x and Fedora 19/18/17

从Spring Boot 1.5升级到2.0

POM 1.5 <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.10.RELEASE</version> <relativePath/> </parent> 2.0 <parent> <group

Spring Cloud 微服务中搭建 OAuth2.0 认证授权服务

在使用 Spring Cloud 体系来构建微服务的过程中,用户请求是通过网关(ZUUL 或 Spring APIGateway)以 HTTP 协议来传输信息,API 网关将自己注册为 Eureka 服务治理下的应用,同时也从 Eureka 服务中获取所有其他微服务的实例信息.搭建 OAuth2 认证授权服务,并不是给每个微服务调用,而是通过 API 网关进行统一调用来对网关后的微服务做前置过滤,所有的请求都必须先通过 API 网关,API 网关在进行路由转发之前对该请求进行前置校验,实现对微服

spring boot项目添加swagger 2.7.0(只需两步操作)

1.pom.xml引入swagger 2.7的jar包 <!-- swagger2 rest api start--> <dependency> <groupId>io.springfox</groupId> <artifactId>springfox-swagger2</artifactId> <version>2.7.0</version> </dependency> <dependenc

Spring Batch 中文参考文档 V3.0.6

1 Spring Batch介绍 企业领域中许多应用系统需要采用批处理的方式在特定环境中运行业务操作任务.这种业务作业包括自动化,大量信息的复杂操作,他们不需要人工干预,并能高效运行.这些典型作业包括:基于时间的事件处理(例如:月底结算,通知或信函):重复的.数据量大的.业务逻辑规则错综复杂的定期任务(例如:保险盈利决策和利率调整):来自内外部不同应用系统的信息集成任务,这些信息需要进行格式化.校验,并通过事务的方式处理成为系统可用的记录.批处理程序就是用来处理这种数以亿计的企业日常事务. Sp