spring-cloud-dataflow

0열

1답변

가능한지 확실하지 않습니다. 나는 하나의 SCDF 스트림이있는 시나리오가 있습니다 소스 | 프로세서 | 싱크대. 그것은 완벽하게 잘 작동합니다. 이제 "소스 | 프로세서 | 싱크"과 같은 구조를 포함하는 다른 스트림을 생성해야합니다. 비즈니스 요구 사항에 따라 두 스트림이 서로 통신하는 작업을 수행해야합니다. 예 : 내 Stream-1 싱크는 한 목록을 S

0열

1답변

Spring Cloud Dataflow를 사용한 컨텐츠 기반 라우팅

Spring Cloud Dataflow를 사용하여 컨텐츠 기반 라우팅 및 필터링을 수행해야한다. 예 : 내 processor에 대한 입력이 String 인 경우. 문자열에 xyz이 있으면 내 Spring Cloud Stream에있는 구성 요소/단계 X에 전달해야합니다. 그렇지 않으면 구성/단계 Y 내 스트림으로 이동합니다. 나는 동일한 것을 달성하기 위해

0열

1답변

실패 단계 DB

내가 구성 작업의 동작을 처리 오류를 시뮬레이션하고 있습니다 에 기록되지는 failedTask 구성 작업 정의는 다음과 같습니다 <f1: sampleTask --fail=true --custom-argument=someMessage || f2: sampleTask> sampleTask 클래스 러너 : public class SampleTask impleme

0열

1답변

Spring Cloud Data Flow에서 Avro 구현하기

데이터베이스에서 레코드를 읽어들이는 Spring Cloud Dataflow 스트림을 구현하려고하는데,이를 Avro 스키마로 변환 한 다음이를 싱크 애플리케이션에서 사용하도록 전달하는 프로세서로 전달합니다. 데이터 원본을 SQL 데이터베이스에서 소스 응용 프로그램으로 전송하고 문제없이 카파 바인더를 통해 데이터를 전달합니다. 프로세서에서 싱크 응용 프로그램

1열

1답변

Spring Cloud Task가 SCDF에서 작동하지 않을 수 있습니다. Kubernetes

저는 SCDF Kubernetes Server를 사용하여 Spring Cloud Task를 배포합니다. 내가 SCDF는 Kubernetes 서버의 봄 클라우드 작업을 시작할 때, 나는이 이상한 문제를 발견, 세부 사항은 아래를 참조하십시오 : 봄 클라우드 작업을 배포, 인수와 함께 포드가는 Kubernetes, see Pod picture에서 생산됩니다.

1열

1답변

스프링 클라우드 데이터 플로우 서버 규모 조정 방법

일반적으로 머신의 스프링 클라우드 데이터 플로우 Jar 파일을 실행하지만, 기간이 지나면 머신에 많은 플로우가 생성되고 서버가 과부하되어 단일 point of failure, 우리는 다른 시스템에서 스프링 클라우드 데이터 플로우 서버 항아리를 실행할 수있는 곳을 가지고 있으며, 그러한 장애를 피하고 전체 시스템을보다 탄력 있고 견고하게 만들 수 있도록 흐름

0열

1답변

Spring Cloud Stream : Sink에서 RabbitMQ 연결이 끊어졌습니다.

로그 싱크 스트림 app 종속성이있는 사용자 정의 Spring 클라우드 스트림 싱크가 RabbitMQ 중단 중에 RabbitMQ 연결을 잃어 버리고 5 회 연결 시도를 시도한 다음 해당 사용자를 중지합니다. RabbitMQ가 정상적으로 연결되면 앱을 수동으로 다시 시작해야 연결됩니다. rabbitMQ 바인딩 here의 기본 속성을 볼 때 간격 시간이 있지만

0열

2답변

Spring Cloud 데이터 흐름을 원격 디버깅하는 방법 Task

우리는 Spring XD를 사용하여 일부 배치 작업을 실행하고 Spring Cloud Dataflow를 사용할 것을 고려하고있다. 이를 위해 원격으로 작업 실행을 디버그하고 싶었고 작업을 수행 할 수 없었습니다. 작업을 호출하는 동안 spring.cloud.deployer.local.javaOpts=Xdebug -Xrunjdwp:transport=dt_so

2열

1답변

스프링 클라우드 스트림 애플리케이션 웹 인터페이스

스프링 클라우드 스트림 애플리케이션에 대한 웹 인터페이스를 만들 수 있습니까? 많은 소스 (파일, http, ftp)는 일반적인 형식으로 변환하기 위해 응용 프로그램에 데이터를 보내고 개발을 줄이기 위해 사용자가 쉽게 데이터 변환을 구성 할 수있는 웹 인터페이스를 만들려고했습니다.

0열

1답변

Ambari에서 SCDF 플러그인을 시작하는 중 오류가 발생했습니다.

Ambari를 사용하여 SCDF를 설치했지만 Spring Cloud Dataflow 서버를 성공적으로 시작할 수 없습니다. 여기 03:07:30.592 [main] ERROR org.springframework.boot.SpringApplication - Application startup failed java.lang.IllegalStateExcepti