spring-cloud-stream

0열

1답변

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

0열

1답변

Transformer를 사용하지 않고 TestSupportBinder에서 채널을 얻는 방법

TestSupportBinder를 사용하여 스프링 클라우드 스트림 응용 프로그램에 대한 테스트를 작성하려고합니다. official documents 및 official github을 포함하여 내가 발견 한 모든 예제는 Processor을 Transformer으로 테스트해야합니다. 이 테스트에서는 Tranformer을 사용하여 출력 채널을 가져오고 채널 객체

0열

1답변

스프링 스트림이 IBM MQueue에서 큐가 아닌 토픽을 만들려고 시도합니다

spring-cloud-stream-binder-ibm-mq을 사용하여 MQueue에서 스프링 부트 스트림을 사용하는 방법을 알아 내려고하고 있습니다. 나는 MQueue에 연결할 수 있지만 Could not provision topic 'queue///EMB_DEV_QUEUE'과 MQJE001: Completion Code '2', Reason '2035'

2열

1답변

파티션 기반 제작자를 만들기 위해 RMQ 및 스프링 클라우드 스트림을 사용하는 방법은 무엇입니까?

저는 RMQ를위한 parition 기반의 제작자를 생성하는 봄 구름 스트림의 예를 찾으려고합니다. RMQ가 주제에 대한 분할을 기본적으로 지원하지 않기 때문에 대기열에 대한 바인딩을 만드는 방법을보고 싶지만 분할 수와 동일한 수의 대기열을 생성합니다 (이 글을 읽었을 때, 잘못되었을 수도 있음). 먼저 파티션 기반 제작자 용 RMQ에서 스프링 클라우드 스트

0열

1답변

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

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

0열

1답변

스프링 부트 1.5.3 로컬 CDF 서버

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

-1열

1답변

어떤 공식적인 Spring Cloud Stream Apps 소스 저장소입니까?

저는 새로운 트위터 사용자 타임 라인 소스 스트림 애플 리케이션을 Spring Cloud Stream Apps에 추가하고 싶습니다만, 어떤 소스 코드를 포크로 만드는지 혼란 스럽습니다. Spring Cloud Stream Apps에는 두 개의 소스 저장소가있는 것으로 보입니다. 이 하나 (https://github.com/spring-cloud/spring

0열

1답변

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

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

1열

1답변

Spring Cloud Stream Rabbit에서 수동 응답을 관리하는 방법은 무엇입니까?

나는 특히 this previous post을 기반으로 RabbitMQ를 사용하여 수동 확인을 관리하는 여러 방법을 시도했지만 불행히도 그 중 아무 것도 작동하지 않습니다. 내 구성 파일에서 , 나는 다음과 같이 수동으로 인정 모드를 설정 : @StreamListener(SinkInterface.NAME) public void receive(

-3열

1답변

스프링 클라우드 스트림과 카프카의 오디오 파일을 넣어 내가 카프카에서 JSON과 오디오 파일을 넣어 tryning있어

, 그녀는 내가 이런 내 파일을 얻기 위해 노력하고있어 소비자의 코드 producer Code 입니다 Consumer code 오류 : org.springframework.messaging.MessagingException : com.sofrecom.service.VoiceCampaignCreator # 1 프로세스를 호출하는 동안 발생한 예외 [1 인수]