spring-cloud-dataflow

1热度

1回答

Spring Cloud Stream Kafka consumer with time based auto commit

我有一个使用Kafka活页夹的Spring Cloud Stream应用程序。它似乎是基于AckMode=BATCH自动提交补偿（必须在调试模式下找到它，因为它没有出现记录）。这会给代理提交频率带来很大的开销。我想无论是切换到使用本地卡夫卡自动提交，如： enable.auto.commit: true auto.commit.interval.ms: 5000 或切换到使用时配置与500

0热度

1回答

如何更改stdout和stderr任务文件目录？

在Linux中，任务执行的spring-cloud-dataflow本地服务器日志是/ tmp/spring-cloud-dataflow- *。我需要在其他地方创建这些特定于任务的目录，而不是/ tmp。例如而不是的/ tmp /弹簧云dataflow- {数}/{任务名称} - {数}/{任务名称} - {} UUID 在有它：的/ opt/MYAPP /日志/ spring-cloud

0热度

1回答

Spring Cloud DataFlow：获取有效载荷作为列表<Map>

使用Spring Cloud DataFlow 1.3.0.M2与Spring Cloud Stream Starters Celsius.M1。我有两个处理器。首先产生一个List<Map>，它应该被另一个消耗掉。这里是简化的代码。 // Processor 1 @StreamListener(Processor.INPUT) @SendTo(Processor.OUTPUT) // N

1热度

1回答

tasklaunchrequest变换忽略净荷

0热度

1回答

检查春季云流源和宿数据内容的方法

有没有什么办法可以检查春季云数据流流源中有什么数据（比如某个命名的目的地“mySource”）和宿（说“日志”为宿）？ e.g. dataflow:>stream create --name demo --definition ":mySource>log" 这里有什么在mySource和日志 - 如何检查？难道就像我必须检查春天的云数据流日志某处得到任何线索，如果它有日志？如果是这样，Wi

1热度

1回答

DLQ中没有嵌入异常

我已经设置了包含kafka活页夹的弹簧云流。我还启用了DLQ，并设置了headerMode捕获异常消息，如here所述。但是，如果有例外情况，我只能在我的kafka主题中看到没有例外情况的消息。我application.yml看起来像这样 spring: application: name: Sample Stream cloud: stream:

1热度

1回答

Spring云任务不能在SCDF上启动Kubernetes

我使用SCDF Kubernetes Server来部署Spring Cloud任务。当我启动新加坡民防部队Kubernetes服务器上春云任务，我发现两个奇怪的问题，请参见下面的细节：部署春季云任务的时候，用参数的吊舱将在Kubernetes，see Pod picture生产。问题在于Pod的参数无法传递到Spring Cloud任务。当我启动Spring Cloud Task时，如果我想

1热度

1回答

如何缩放弹簧云数据流量服务器

通常情况下，我们在其中一台机器上运行弹簧云数据流Jar，但如果在此期间我们在机器上创建了许多流量，并且服务器变得过载并成为单个我们是否有一件事情可以在另一台机器上运行Spring云数据流服务器jar，并将这些数据流转换为这样的数据流，以便我们可以避免任何此类故障，并使我们的完整系统更具弹性和强大。或者当我们在PCF /或云代工厂部署完整系统时，扩展会自动发生。

0热度

1回答

这是在春天的云数据流中的错误：选项卡创建2个额外的kafka队列和额外的桥梁弹簧启动应用程序

对于我使用它创建额外的桥梁实例和两个更多的kafka话题，小号 So - source p - processor s - sink 用例，用于创建数据为新的记录流流动 1）应如此=>取值 2），用于更新记录流应如此=> p =>取值 DSL: demo1=so|p > :foo demo2=:demo1.so > :foo demo3=:foo > s 问题： 1）这里的数据将

2热度

1回答

如何配置Spring Batch的

春天数据流我有春天一批项目，我想在春天的云数据流我为能够将其注册在新加坡民防部队，但在发射任务我的作业没有运行，以下配置它是我的配置文件 @SpringBootApplication @EnableBatchProcessing @EnableTask public class BatchApplication { /*@Autowired BatchCommandLineRunner