spring-cloud-dataflow

0열

1답변

SpringCloud Dataflow에서 Kafka Source/Sink를 사용하고 싶습니다.하지만 spring-cloud-stream-app-starters에서 app-starters를 찾을 수 없습니다. 스프링 XD에서 사용할 수 있습니다. 왜 그들이 사라 졌는지 아는 사람 있습니까? 감사

0열

1답변

원시 헤더가있는 null/tombstone 메시지 게시

카프카 (Cefka) 주제에서 문자열 키와 null 페이로드가있는 원시 데이터를 사용하는 Spring Cloud Stream Kafka 프로세서 응용 프로그램을 빌드하고 있습니다. String key와 null 페이로드 (Kafka 내의 묘비라고도 함)를 다른 주제로 생성하려고합니다. 메시지에 원시 헤더를 사용하려면 바이트 []를 출력해야하지만, Kafka

0열

1답변

봄 구름 데이터 흐름에서 주제를 만드는 방법은 무엇입니까?

스트림 원본의 카프카에서 별도의 항목으로 내 원본의 마지막 읽기 레코드를 저장하려고합니다. 어떻게 스프링 클라우드 데이터 흐름 스트림 응용 프로그램을 통해 이것을 달성 할 수 있습니다. 모든 제안은 큰 도움이 될 것입니다.

0열

2답변

Kubernetes/Spring Cloud 데이터 흐름 스트림> spring.cloud.stream.bindings.output.destination이 생성자에 의해 무시됩니다.

다음에 설명 된 간단한 예제를 기반으로 "Hello, world"스프링 클라우드 데이터 흐름 스트림을 실행하려고합니다. . 저는 간단한 소스를 만들고 싱크대를 만들고 카프카를 사용하여 로컬 SCDF 서버에서 실행할 수 있습니다. 그래서 여기까지 모든 것이 정확하고 SCDF에 의해 지정된 주제에서 메시지가 생성되고 소비됩니다. 이제는 http://docs.s

0열

1답변

LoadBalancing Spring 클라우드 데이터 흐름 서버

봄 클라우드 데이터 흐름에서는 각 스트림이 마이크로 서비스이지만 데이터 흐름 서버는 이해하지 못합니다. 내가 맞습니까? SCDF (Spring Cloud Dataflow) 서버의 인스턴스를 여러 개 가질 수 있습니까? 데이터 흐름 서버를로드 밸런싱하는 방법은 무엇입니까? AWS에 배포 할 계획입니다. 공식 문서에서는 데이터 흐름 서버의로드 밸런싱에 대해 언

0열

1답변

scdf UI에 대한 경로 접두어를 설정하는 방법

scdf UI의 경로 접두사를 어떻게 설정할 수 있습니까? 나는 나머지 API에 대해 작동하는 tomcat 속성 (예 : server.contextPath =/api /)을 설정했지만 UI는 여전히 오류를 제공합니다. Info : 나는 그것을 입구를 사용하여 Kubernetes에서 돌리고있다.

0열

1답변

Spring Cloud에서의 JMS 브리지 Cloudflow 데이터 흐름

Spring Cloud Data Flow에서 JMS 브리지를 한 서버의 주제와 다른 서버의 다른 주제 사이에서 설정하려면 어떻게해야합니까? 내 문제는 JMS 소스가 있지만 서버 주소/사용자 이름/비밀번호 (Tibco EMS를 사용 중입니다)를 설정하는 방법을 모르겠다는 것입니다. 또 다른 문제는 JMS 싱크가 보이지 않는다는 것입니다.

1열

1답변

클라우드 파운드리에서 https로 데이터 흐름 사용

Cloud Foundry에 데이터 흐름 서버를 배포하고 간단한 응용 프로그램을 만들려고합니다. https 끝점 만 노출 될 수 있습니다. 다음을 사용하여 https를 활성화 할 수 없습니다. http://docs.spring.io/spring-cloud-dataflow/docs/current-SNAPSHOT/reference/htmlsingle/#confi

0열

1답변

별도의 싱크 및 소스가있는 Spring Cloud 데이터 흐름 앱

SCDF를 사용하여 배포하려는이 애플리케이션을 보유하고 있습니다. 메시지 (싱크)를 수신하여 비 결정적 또는 간단한 파이프 라인 시스템을 통해 비동기 적으로 처리합니다. 결국, 출력을 생성하지 않을 수도 있습니다. 출력이 생성되면 다른 응용 프로그램이 사용할 메시지 (원본)를 생성하려고합니다. 응용 프로그램은 둘 이상의 jvm으로 분할 될 수 없지만 두 개

0열

1답변

점점 오류 : 조직의 기본 스트림을 배포하는 동안 ticktock2.time이

을 "이미"오류 항목이 이미에 의한 존재 가져옵니다. apache.kafka.common.errors.TopicExistsException : 주제 "ticktock2.time"이 이미 존재합니다.