spring-cloud-dataflow

0열

1답변

저는 Spring Cloud Date Flow를보고 Activiti와 Camunda (워크 플로우 엔진)를 보았습니다. 워크 플로와 데이터 흐름과 같은 개념의 차이점을 이해할 수 없습니까? Spring Cloud Data Flow를 워크 플로우 엔진이라고 부릅니다. 죄송합니다.이 주제의 최신 버전입니다. 나는 어떤 대답이라도 기뻐할 것입니다!

0열

1답변

하나의 프로세서/싱크에 공급되는 2 개의 소스가있는 스프링 데이터 플로우

특정 유스 케이스에 대한 스프링 데이터 플로우 스트림 설정에 대한 조언을 찾고 있습니다. 내 사용 사례 : 내가이 RDBMS를 가지고 있고 각각에 대해 실행 쿼리의 결과를 비교해야합니다. 쿼리는 대략 동시에 실행해야합니다. 비교 결과에 따라 필자가 만든 사용자 지정 전자 메일 싱크 응용 프로그램을 통해 전자 메일을 보낼 수 있어야합니다. 내 지식 문제는,

0열

1답변

SpringXD에서 Spring Cloud 데이터 플로우로의 마이그레이션

우리는 현재 SpringXD를 사용하여 다양한 데이터 소스의 데이터를 싱크 (sinks)로 수집하고있다. Springxd는 가용성이 끝날 예정이므로 Spring Cloud 데이터 플로우로 마이그레이션하고 싶습니다. 우리는 SpringXD 용 사용자 정의 모듈을 여러 개 작성했습니다. SCDF에서 동일한 모듈을 사용하는 방법. SCDF에서 이들을 사용하기 위

0열

1답변

스프링 부트 1.5.3 로컬 CDF 서버

로컬 CDF 서버를 확장하려고합니다. 나는 다음과 같은 종속성을 사용하고 있습니다 : <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-datafl

0열

1답변

Spring Cloud Stream 용 Spring Cloud Dataflow (예 : Apache Ignite 또는 다른 InMemory 저장소)에 내 데이터 저장소를 사용할 수 있습니까?

tests spring cloud dataflow SpringDefinition - HashMap을 저장하는 데 사용 된 것으로, 같은 HashMap과 같이 InMemory에 스트림 및 작업을 저장하는 데 필요한 DateFlowServerConfiguration의 구성을 재정의 할 수 있습니까? 그렇다면 어떻게해야합니까?

0열

1답변

봄 구름 작업 및 데이터 흐름을 사용하는 logstash, config server 및 eureka 사용

우리는 logstash, config 및 eureka 서버가있는 기존 마이크로 서비스 환경을 보유하고 있습니다. 우리는 현재 Spring Cloud Dataflow (Kubernetes) 환경 (주로 작업/배치 작업을 실행하기위한 초기 단계)을 설정 중입니다. 작업이 로그를 실행하면 : Logstash : 이상적으로 우리는 다음과 같은 시나리오를 지원하기

1열

1답변

Spring Cloud Data Flow 배포 중 오류가 발생했습니다.

IBM Cloudemix에 Spring Cloud Data Flow를 배치하려고합니다. 내가 참조 문서 http://docs.spring.io/spring-cloud-dataflow-server-cloudfoundry/docs/1.1.1.RELEASE/reference/htmlsingle/ 의 모든 지시 사항을 준수 이 내가 결국 오류입니다 [CELL/0]

0열

1답변

Dataflow 1.2.0 YAML 구성 변경

어제 개발 환경을 Spring Cloud Dataflow 1.2.0 및 모든 싱크/소스 앱 종속성으로 업그레이드했습니다. 나는 두 가지 문제가 있습니다 javaOpts : -Xmx128m 그렇게 지역적으로 배치 된 애플리케이션이 기본의 -Xmx 값이, 포착되지 않는 이상됩니다. 다음은 이전에 작동 한 Dataflow yaml config의 형식입니다. Se

0열

2답변

Spring Cloud Dataflow 서버 로그 관리

docker를 사용하여 스프링 클라우드 데이터 플로우 서버를 배포하고 있습니다. 스프링 부트 응용 프로그램을 소스, 프로세서 및 싱크로 배포하여 데이터 흐름 서버 내부에 데이터 처리 파이프 라인을 만들었습니다. 각 서비스의 로그에 액세스하려면 docker continer (bash) 내부에서 꼬리를 잡아야합니다. 그렇지 않으면 도커 컨테이너에서 로컬 디스크

1열

1답변

SCDF 스트림을 다시 배포 할 때 카프카 오프셋 용량이 어떻게 바뀌나요?

나는 Kafka 0.10.0과 함께 SCDF on YARN 1.0.2.RELEASE을 사용하여 스트림 응용 프로그램에 사용합니다. 스트림 배포를 취소 한 다음 다시 배포하면 현재의 카프카 항목 오프셋에서 계속 진행되는 경우가 있지만 때로는 가장 오래된 오프셋에서 시작하는 경우가 있습니다. 어디에서 스트림을 재배포 할 때 예측 가능한 동작 (예 : 현재 오프