Spring Cloud Data Flow是用于构建数据集成和实时数据处理管道的工具包。管道由Spring Boot应用程序组成,使用Spring Cloud Stream或Spring Cloud Task微服务框架构建。这使得Spring Cloud Data Flow适用于各种数据处理用例,从导入/导出到事件流和预测分析。
使用Prometheus监控和管理Spring Cloud Data Flow(SCDF)服务器
是否可以使用Prometheus监控和管理Spring Cloud Data Flow(SCDF)服务器本身? 我知道,我可以监视和收集 SCDF 服务器中部署的 jar 的指标(即源代码,
DataflowTemplate 在构造函数调用时进行 HTTP 调用
当我调用构造函数时,我用来启动部署到 Spring Cloud Dataflow 的任务的 DataFlowTemplate 会执行对 SCDF 服务器的 HTTP 调用,例如 新的数据流模板(...
带有 Oauth2 安全配置的 Spring Cloud Data Flow http 源应用程序
我试图在 SCDF 中的 http-source-kafka 连接器上配置 Oauth2 服务器。没有此类属性可用于配置 Oauth2 相关配置。 allowed.endpoints=xxx 受限制。
Spring-cloud-dataflow:如何默认使用 RabbitMQ 绑定器来创建仲裁队列
我正在使用最新的 Spring Cloud Dataflow,使用 RabbitMQ 作为消息代理,并注意到从 http-source 和 log-sink 在 RabbitMQ 上创建的队列是经典的......
Spring Cloud Dataflow 和 Mysql 5.6 的问题
尝试启动连接到Mysql 5.6的SCDF服务器时遇到以下问题。 使用以下命令启动连接到 mysql 数据库(版本 5.6)的 SCDF 服务器: java -jar spr...
找不到 Spring Cloud 数据流的仪表板 - 404
我正在尝试创建一个 Spring Cloud Dataflow 服务器 v2.10.3,但是当我运行该项目时,我无法访问仪表板,它给了我一个 404 错误...... 这是我的主要课程: @EnableDataFlowServer @
Spring Cloud Data Flow 2.10.3:我可以启动链接到特定应用程序版本而不是默认版本的任务吗
我想运行一个任务(或创建一个新任务并运行它),其执行将触发链接应用程序的指定(在任务级别)版本的部署和执行。 我不知道如何...
我们正在使用 spring cloud dataflow 2.10.3,在 kubernetes 集群中使用 helm 部署。 我不确定这是一个错误还是做错了什么,但我们已经看到它发生在所有类型的流中,
为什么在 Spring Cloud Data Flow 中启动任务后没有销毁?
我创建了一些 Spring Batch 项目并使用 Spring Cloud Data Flow (SCDF) 部署这些作业。 在 SCDF 中启动任务(作业)后,它会创建 JVM 来执行任务(作业)。 然而当任务...
Spring 云流:反应式管道中的异常导致流崩溃,并显示错误调度程序没有订阅者
我有以下消费者功能。如果 WebClient 调用成功则有效 @豆 有趣的消费者()=消费者> { 通量-> Flux.concatMap { s -> WebCli...
将 Spring Cloud Connector 迁移到 Cloudfoundry 中的 java-cfenv 导致 Rabbit-MQ 服务的 TLS 失败
在将 Spring Cloud Services 从 2.4.1 升级到 3.5.5 时,我们发现应用程序无法连接到 Cloud Foundry 中的 Rabbit MQ 服务。它抛出以下异常:- c.r.客户...
无法从源代码构建 scdf,缺少依赖项:io.pivotal:pivotal-cloudfoundry-client-reactor:jar:2.1.0.RELEASE
在maven中央仓库中,只有2.2.0-Relase可用。 https://central.sonatype.com/artifact/io.pivotal/pivotal-cloudfoundry-client-reactor/2.2.0.RELEASE/versions 但是scdf有一个depe...
本地部署spring cloud data flow时连接rabbitmq失败
我参考了文档:https://dataflow.spring.io/docs/installation/local/manual/在我的本地mac中运行spring cloud data flow,然后部署了一个http |根据 htt 记录流...
我有以下简单的消费者应用程序。我想知道如何使消费者仅在当前异步进程完成后才拉取下一条消息 @SpringBootApplication 公开课应用程序{...
我正在使用Spring Cloud Stream功能模型 如果有人可以帮助了解哪个性能更好 功能 或者 功能 或者 功能 我正在使用 Spring Cloud Stream 功能模型 如果有人可以帮助了解哪个性能更好 功能 或者 功能 或者 功能、消息>
在 Spring SCDF 中,我有一个只有一个输入的处理器,我想根据数据类型将数据发送到 3 个不同的接收器,例如:整数到 sink1,字符串到 Sink3 和 Longs 到 SInk3,每个...
Spring Cloud Dataflow 自定义流应用程序指标未显示在 Grafana 中
SCDF 版本 2.10.2 我无法让我的自定义源、处理器或接收器向我的 prometheus/grafana 设置公开指标。 我在这里遵循了自定义流应用程序教程:https://dataflow.sp...
在 SCDF(Spring Cloud Data Flow)中,我如何将应用程序(流或任务)部署为有状态集?不是部署
在 SCDF(Spring Cloud Data Flow)中,我如何将应用程序(流或任务)部署为有状态集?不部署 我可以找到一些与 statefulset 相关的属性(例如:statefulsetInitcontainer,
Spring Cloud StreamBridge to Kafka delivery check
我对自己拥有的spring cloud stream有几点要求: 它需要从一个集群上的单个 Kafka 主题获取 KStream,并将消息发送到另一个集群上的多个主题。 在一些
onConfiguration$FunctionBindingRegistrar :您定义了不存在的函数定义:mongoSink
基本上我正在将 mongo 接收器(消费者)应用程序从基于注释的方法切换到使用消费者 bean 的功能模型。 新代码 @豆 公共消费者>输入(