spring-cloud-dataflow

1열

1답변

Spring Cloud 데이터 흐름에 대한 본 릴리스 발표를 읽는 중입니다. https://spring.io/blog/2017/02/22/spring-cloud-data-flow-for-cloud-foundry-1-1-1-maintenance-release-available 나는 우리가 성공적으로 스프링 클라우드 데이터 응용 프로그램은 ..이 작업 스트림이

0열

1답변

Spring Cloud Data Flow 서버가 다시 시작될 때 모든 응용 프로그램을 등록 해제합니다.

로컬 컴퓨터에 스프링 클라우드 데이터 플로우 서버를 설치할 수 있습니다. 쉘에서 응용 프로그램, 그것은 응용 프로그램 목록 명령에 표시 할 수있는 아웃 - 오브 - 박스 내가 가져 오기를 일괄 때 지금 https://cloud.spring.io/spring-cloud-dataflow/#quick-start : I는 아래의 링크를 따라 설치 기본 카프카 기반

0열

1답변

SCDF에서 두 개의 서로 다른 출력 채널로 메시지를 보내는 방법은 무엇입니까?

메시지를 기본 output 채널을 통해 스트림의 프로세서로 보내는 원본이 있습니다. 이제 도 다른 채널을 통해 오류 메시지를 보내려고합니다. 나는 Source에서 확장 할 수있는 바인딩 가능한 인터페이스를 만들고 @Output을 사용하여 추가 채널을 추가해야한다고 생각했습니다. SCDF가 실제로이 채널에 대한 카프카 (Kafka) 주제를 실제로 만들도록하려

0열

1답변

contentType은 HDFS 싱크에서 쓰여진 데이터에 접두사가 붙습니다.

HDFS 싱크를 사용하고 HDFS에 쓰고 있습니다. 하지만 HDFS에 쓰는 페이로드에는? contentType "text/plain"접두사가 붙습니다.하지만 페이로드에는 없지만 말입니다. 접두어가 붙은 이유와 제거 방법을 알려주십시오. 스트림 만들기 - 정의 : 스트리밍 --spring.cloud.stream.bindings.output.producer.h

0열

2답변

스프링 클라우드의 동물원 데이터 흐름 끊기 계속

도커로 SCDF를 시작하려고합니다. 그것은 잘 시작하지만 모든 스트림을 배포 할 때 나는 스프링 클라우드 데이터 플로우 서버 로컬 1.1.4 사용하고 응용 프로그램 로그 2017-03-09 15:19:45.864 INFO 62 --- [ main] kafka.utils.VerifiableProperties : Verifying properties

1열

1답변

봄 스트림 라우터 싱크 나는 다음과 같은 스트림 배포하려고 CDF

에 시작되지 않습니다 *************************** APPLICATION FAILED TO START *************************** Description: Parameter 1 of method router in org.springframework.cloud.stream.app.router.sink.Rout

0열

1답변

PCF의 Spring Cloud 데이터 흐름 컨테이너 내에서 여러 개의 스프링 클라우드 작업 작업 실행

PCF의 스프링 클라우드 데이터 흐름 컨테이너 내에서 여러 개의 스프링 클라우드 작업 작업을 실행하려고합니다. 이 작업은 HTTP 소스에서 원시 파일을 읽은 다음 을 구문 분석하고이를 mysql db에 씁니다. 이러한 작업은 스프링 배치가 아닌 일반 Java로 작성됩니다. PCF의 scdf 컨테이너에 mysql db를 바인드했습니다. 나는 스프링 클라우드

0열

1답변

맞춤 프로세서 응용 프로그램에서 MongoProperties를 허용하는 방법은 무엇입니까?

MongoDB에서 데이터를 읽는 사용자 정의 프로세서 응용 프로그램을 작성했습니다. 이 응용 프로그램에서는 MongoDB 작업을 위해 MongoTemplate을 사용하므로 SpringBoot는 속성로드를위한 클래스 인 MongoProperties 클래스를 제공합니다. 그러나 WebUI 대시 보드에서 이러한 속성을 볼 수 있도록 MongoProperties를

1열

1답변

return 문에 Java 람다 형식의 객체 캐스트가 있습니까?

나는 나의 봄 클라우드 애플리케이션 코드를 다음 있습니다 : @EnableBinding(Source.class) @SpringBootApplication public class dataflow_producer { static SimpleDateFormat dateFormatter = new SimpleDateFormat("hh:mm:ss"); p

0열

1답변

Spring CloudDataflow에서 X 시간 이후에 스트림 배포를 취소하는 방법은 무엇입니까?

Spring CloudDataflow 서버에 스트림을 배포하고 누군가가 이전에 배포 취소하지 않으면 24 또는 48 시간 후에 자동으로 배포를 취소해야합니다. 아무에게도 내가 어디서부터 시작해야할지 모르므로 접근 방법을 알려 줄 수 있습니까? 도움이 필요합니다.