spring-cloud-dataflow

0열

1답변

재귀 작업에 spring-cloud-dataflow (kubernetes)를 사용할 수 있습니까? 현재 결과에 따라 흐름의 새 인스턴스를 만들어야합니다 (재귀 적). 분산 된 작업 처리가 필요합니다. 1) message-source를 사용해야합니까? 내가 이해하지 못하면 dataflow는 자체 메시지 브로커 (rabbit, kafka)를 사용합니다. 다른

0열

1답변

Spring Cloud Data Flow의 Spring Cloud Stream이 트리거 될 수 있습니까?

우리는 데이터베이스 테이블에서 데이터의 각 항목을 처리해야하는 시나리오가 있습니다. 그러나 이것은 사용자가 처리를 시작하기로 결정할 때 트리거되어야합니다. 각 프로세스 단계를 스트림 응용 프로그램으로 분리하고 필요에 따라 확장 할 수 있으므로 스트림 처리가 만족 스럽습니다. 우리가 가지고있는 다른 옵션은 일괄 작업으로 작업을 수행하는 것입니다. 우리가 이것

0열

2답변

스프링 데이터 흐름 및 원사 : 속성을 올바르게 설정하는 방법?

어떻게 기본 appdeployappmaster 속성을 변경할 수 있습니까? Spring DataFlow YARN을 통해 응용 프로그램을 배포하려고 할 때. 내 앱을 등록하고 스트림을 만든 다음 '배포'버튼을 클릭합니다. 예외 응용 프로그램의 StreamAppDefinition을 배포 [streamName의 = 히스, 이름 = 내-앱 registeredApp

0열

1답변

Spring DataFlow를 사용하여 자율 응용 프로그램을 배포하는 방법은 무엇입니까?

내 응용 프로그램이 구성된 Kafka에서 주제를 읽은 다음 변환 된 결과를 Hadoop HDFS에 쓰도록 구성되었습니다. 이를 수행하려면 Yarn 클러스터 노드에서 실행해야합니다. 이렇게하려면 Spring DataFlow를 사용하고 싶습니다. 그러나이 응용 프로그램은 다른 흐름에서 입력을 필요로하지 않으므로 (이미 소스를 가져올 위치를 알고 있습니다.) 아

1열

1답변

Spring Cloud 데이터 흐름 : Kubernetes 클러스터에서 작업을 시작할 수 없습니다.

로컬 Kubernetes 클러스터에 Spring Cloud Data Flow 서버를 배포했습니다. 모두 괜찮아 보인다. 그런 다음 스프링 부트 JAR의 URL을 제공하는 Task 유형의 App을 생성합니다. 그러면 '정의'작업을 만들고 실행합니다. 'launching'상태에서 작업 정의가 중단됩니다. 나는 포드이 포드는 image: /tmp/deployer

0열

1답변

Spring 클라우드 데이터 흐름 샘플 소스를 실행할 때 DestinationReslutionException이 발생했습니다.

샘플 spring-cloud-dataflow 소스 애플리케이션을 실행하는 데 문제가 있습니다. 코드 0으로 응용 프로그램이 종료됩니다 (작동 중이어야합니다). 나는 그것을 디버깅하고 다음과 같은 예외가 발생되는 것을 발견 : DestinationResolutionException: failed to look up MessageChannel with name

1열

1답변

Kafka에서 Spring Cloud Dataflow를 사용하여 CSV 파일을 스트림

Spring Cloud dataflow 및 Kafka로 csv 파일을 스트리밍하려고합니다. 아이디어는 각 줄에 포함 된 머리글을 사용하여 줄 단위로 파일을 스트리밍하는 것입니다. 예를 들어, 내 csv 파일의 내용 street,city,zip,state 3526 HIGH ST,SACRAMENTO,95838,CA 51 OMAHA CT,SACRAMENTO,

0열

1답변

Spring Cloud Dataflow Local Server는 사육사를 연결해야합니까?

도커 컨테이너에서 scdf를 설정하려고합니다. 모든 컨테이너는 하나의 네트워크 에있는 두 의 포트 에 의해 노출되고 난 카프카 s는 사육사에 연결하는 확신 카프카 에스. (그렇지 않으면, 그들은 정상적으로 시작되지 않습니다) 그러나 간단한 스트림 stream create --name test --definition "time | log" --deploy

0열

1답변

Spring Cloud DataFlow - TCP 소스에서 사용자 정의 TCP 인코더/디코더를 사용하는 방법

이미 스프링 XD에 대해 this question을 요청했습니다. 지금은 Spring CDF로 마이그레이션하려고합니다. 나는 this link을 발견했으며 코드를 재사용하고 광산으로 인코딩을 변경하려고했습니다. 나는 다음과 같은 POM을 만들어 : <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http:

1열

1답변

스프링 배치 대신 Spring 클라우드 데이터 흐름을 사용하는 이점

매일 플랫 파일을 읽고 데이터베이스 테이블에 쓰는 응용 프로그램을 작성해야합니다. 우리는 Spring Batch를 사용하여이 작업을 수행 할 계획입니다. 우리가 찾고있는 제한 및 추가 자체가 하나의 VM에서 실행됩니다 1. 응용 프로그램입니다. 언제든지 하나 이상의 VM에 배포되지 않습니다. 2. 우리는 앞으로 동일한 패턴을 따르기 위해 다른 파일을 가질