spring-cloud-dataflow 相关问题

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 的指标(即源代码,

回答 1 投票 0

DataflowTemplate 在构造函数调用时进行 HTTP 调用

当我调用构造函数时,我用来启动部署到 Spring Cloud Dataflow 的任务的 DataFlowTemplate 会执行对 SCDF 服务器的 HTTP 调用,例如 新的数据流模板(...

回答 1 投票 0

带有 Oauth2 安全配置的 Spring Cloud Data Flow http 源应用程序

我试图在 SCDF 中的 http-source-kafka 连接器上配置 Oauth2 服务器。没有此类属性可用于配置 Oauth2 相关配置。 allowed.endpoints=xxx 受限制。

回答 1 投票 0

Spring-cloud-dataflow:如何默认使用 RabbitMQ 绑定器来创建仲裁队列

我正在使用最新的 Spring Cloud Dataflow,使用 RabbitMQ 作为消息代理,并注意到从 http-source 和 log-sink 在 RabbitMQ 上创建的队列是经典的......

回答 1 投票 0

Spring Cloud Dataflow 和 Mysql 5.6 的问题

尝试启动连接到Mysql 5.6的SCDF服务器时遇到以下问题。 使用以下命令启动连接到 mysql 数据库(版本 5.6)的 SCDF 服务器: java -jar spr...

回答 2 投票 0

找不到 Spring Cloud 数据流的仪表板 - 404

我正在尝试创建一个 Spring Cloud Dataflow 服务器 v2.10.3,但是当我运行该项目时,我无法访问仪表板,它给了我一个 404 错误...... 这是我的主要课程: @EnableDataFlowServer @

回答 2 投票 0

Spring Cloud Data Flow 2.10.3:我可以启动链接到特定应用程序版本而不是默认版本的任务吗

我想运行一个任务(或创建一个新任务并运行它),其执行将触发链接应用程序的指定(在任务级别)版本的部署和执行。 我不知道如何...

回答 1 投票 0

流部署属性在部署出现错误后被锁定

我们正在使用 spring cloud dataflow 2.10.3,在 kubernetes 集群中使用 helm 部署。 我不确定这是一个错误还是做错了什么,但我们已经看到它发生在所有类型的流中,

回答 1 投票 0

为什么在 Spring Cloud Data Flow 中启动任务后没有销毁?

我创建了一些 Spring Batch 项目并使用 Spring Cloud Data Flow (SCDF) 部署这些作业。 在 SCDF 中启动任务(作业)后,它会创建 JVM 来执行任务(作业)。 然而当任务...

回答 2 投票 0

Spring 云流:反应式管道中的异常导致流崩溃,并显示错误调度程序没有订阅者

我有以下消费者功能。如果 WebClient 调用成功则有效 @豆 有趣的消费者()=消费者> { 通量-> Flux.concatMap { s -> WebCli...

回答 1 投票 0

将 Spring Cloud Connector 迁移到 Cloudfoundry 中的 java-cfenv 导致 Rabbit-MQ 服务的 TLS 失败

在将 Spring Cloud Services 从 2.4.1 升级到 3.5.5 时,我们发现应用程序无法连接到 Cloud Foundry 中的 Rabbit MQ 服务。它抛出以下异常:- c.r.客户...

回答 1 投票 0

无法从源代码构建 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...

回答 1 投票 0

本地部署spring cloud data flow时连接rabbitmq失败

我参考了文档:https://dataflow.spring.io/docs/installation/local/manual/在我的本地mac中运行spring cloud data flow,然后部署了一个http |根据 htt 记录流...

回答 1 投票 0

Spring云流和异步流程

我有以下简单的消费者应用程序。我想知道如何使消费者仅在当前异步进程完成后才拉取下一条消息 @SpringBootApplication 公开课应用程序{...

回答 0 投票 0

消息<String>和消息<byte[]>

我正在使用Spring Cloud Stream功能模型 如果有人可以帮助了解哪个性能更好 功能 或者 功能 或者 功能 我正在使用 Spring Cloud Stream 功能模型 如果有人可以帮助了解哪个性能更好 功能 或者 功能 或者 功能、消息>

回答 0 投票 0

Spring 云数据流一个处理器将海关数据发送到多个接收器

在 Spring SCDF 中,我有一个只有一个输入的处理器,我想根据数据类型将数据发送到 3 个不同的接收器,例如:整数到 sink1,字符串到 Sink3 和 Longs 到 SInk3,每个...

回答 1 投票 0

Spring Cloud Dataflow 自定义流应用程序指标未显示在 Grafana 中

SCDF 版本 2.10.2 我无法让我的自定义源、处理器或接收器向我的 prometheus/grafana 设置公开指标。 我在这里遵循了自定义流应用程序教程:https://dataflow.sp...

回答 0 投票 0

在 SCDF(Spring Cloud Data Flow)中,我如何将应用程序(流或任务)部署为有状态集?不是部署

在 SCDF(Spring Cloud Data Flow)中,我如何将应用程序(流或任务)部署为有状态集?不部署 我可以找到一些与 statefulset 相关的属性(例如:statefulsetInitcontainer,

回答 0 投票 0

Spring Cloud StreamBridge to Kafka delivery check

我对自己拥有的spring cloud stream有几点要求: 它需要从一个集群上的单个 Kafka 主题获取 KStream,并将消息发送到另一个集群上的多个主题。 在一些

回答 1 投票 0

onConfiguration$FunctionBindingRegistrar :您定义了不存在的函数定义:mongoSink

基本上我正在将 mongo 接收器(消费者)应用程序从基于注释的方法切换到使用消费者 bean 的功能模型。 新代码 @豆 公共消费者>输入(

回答 0 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.