Spring Cloud Data Flow是用于构建数据集成和实时数据处理管道的工具包。管道由Spring Boot应用程序组成,使用Spring Cloud Stream或Spring Cloud Task微服务框架构建。这使得Spring Cloud Data Flow适用于各种数据处理用例,从导入/导出到事件流和预测分析。
将RDBMS与Apache Directory Ldap同步
目前,我要求将数据从apache direcotry ldap同步到任何RDBMS数据库(MySQL,PostgreSQL)。目录大约暂时拥有几百万条记录,可能会增长......
repo.sping.io url大部分时间都处于关闭状态,因此无法部署使用Spring云数据流服务器的应用程序
我们正在使用https://repo.spring.io/libs-release/org/springframework/cloud/stream/app/spring-cloud-stream-app-descriptor/Darwin.SR1/spring-cloud-stream-app-descriptor -Darwin.SR1.rabbit-应用Maven的回购-...
是否有一个2.0.0.RELEASE的spring-cloud-starter-dataflow-server-local或者是否有新的方法来创建本地服务器?
Spring Cloud Data Flow 2.0在一周前推出,但本地服务器仍然在1.7.4.RELEASE上的maven中心以及它的启动器。我想知道是否会有新版本的弹簧-...
我们目前正在评估流程从Spring批处理+批处理管理转变为基于Spring Cloud的基础架构。我们的主要挑战/问题:1。作为整体设计的一部分......
人们通常如何处理流应用程序的错误?特别是我正在使用Spring Cloud Dataflow管道。例如,在典型的源中处理器|下沉管道,如果处理器......
我有一个任务应用程序,它有自己的数据库,我想在Spring Cloud Data Flow中运行。我的问题是SCDF用数据源覆盖任务中的数据源配置......
我按照spring示例的指南在我的应用程序中配置了两个数据源:https://github.com/spring-cloud/spring-cloud-task/blob/master/spring-cloud-task-samples/multiple-datasources。春天 ...
Spring Cloud Dataflow - http |卡夫卡和卡夫卡| hdfs - 在HDFS中获取原始消息
我在SCDF(本地服务器1.7.3)中创建基本流,其中我正在配置2个流。 1. HTTP - > Kafka主题2. Kafka主题 - > HDFS流:流创建--name ingest_from_http --...
我们希望为SCDF实施多租户解决方案,每个租户可以拥有唯一的任务定义/等。理想情况下,我们只需要一个SCDF服务器(而不是设置SCDF ...
我正在尝试部署以下流:STREAM_2 =:messages> filter --expression =“#jsonPath(payload,'$ .id')== 1”| rabbit --queues = id_1 --host = rabbitmq --routing-key = id_1 --exchange = ex_1 --own -...
在Spring Data flow应用程序中永久注册应用程序
我已将Spring Data流程和上传的应用程序jar集成到面板中。但是,每当我重新启动数据流应用程序时,我都会使用JAR松开应用程序映射。我怎么能永久地拥有它......
我有一个微服务,他有5个嵌入式批处理作业,每晚00:00运行,我想使用Spring Cloud DataFlow外包这些批次,我的问题是: - 我可以将SCDF连接到...
scdf 1.7.3 docker k8s function-runner无法启动
试图将scdf k8s中的函数运行器部署到流http --server.port = 9001 |中f-run:function-runner --function.className = com.example.functions.CharCounter --class-name = com.example ....
scdf 1.7.3 docker k8s @Bean没有运行,没有日志
作为用户,将处理器编写为云函数,scdf 1.7.3,spring boot 1.5.9,spring-cloud-function-dependencies 1.0.2,public class MyFunctionBootApp {public static void main(String [] ...
Spring Cloud Data Flow + Kubernetes,要求将任务pod部署在非默认名称空间上
我在kubernetes上有一个scdf-server的设置工作正常,它将每个任务部署在一个按需pod上的同一个默认命名空间,即托管scdf-server pod的命名空间。现在,我需要部署......
我正在尝试将jdbc-sink部署到基于Helm的Kuberentes安装Spring Cloud Data Flow。我将如何添加JDBC jar以便使用初学者?我得到以下......
是否可以使用Kubernetes Spring Cloud Dataflow注册google注册表docker容器?
我们的团队正在使用Kubernetes Spring Cloud Dataflow 2.01版,它似乎需要一个明确的docker:// docker容器的URL:https://docs.spring.io/spring-cloud-dataflow/docs/2.0.0 .. ..
我已经从JDBC Sink Starter创建了一个自定义接收器。接收器的输入是JSON内容,但是当接收器收到消息时,我在日志中收到以下错误:属性或字段'...
spring-cloud-dataflow-server-2.0.1.RELEASE.jar我正在尝试在SCDF @ PCF上部署示例任务应用程序。部署失败,出现以下异常:Shell端:未找到Launcher ...
我正在尝试设置Spring Cloud Data Flow(SCDF)以在本地模式下运行,以及几乎没有什么问题可以帮助我确定它是否适合我的要求。尽管建议......