spring-cloud-stream

2열

2답변

저는 (Kafka를 사용하는) 제작자와 둘 이상의 소비자를 보유하고 있습니다. 따라서 주제에 메시지를 게시 한 다음 소비자가 메시지를 수신하고 처리합니다. 적어도 하나의 소비자로부터 응답을 받아야합니다 (첫 번째 경우 더 좋음). RxJava (관측 가능)를 사용하려고합니다. 그렇게 할 수 있습니까? 누구든지 예제가 있습니까?

0열

2답변

Spring Cloud Dataflow 서버 로그 관리

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

1열

2답변

Observable이 완료 될 때까지 스레드를 잠그는 방법

나는 이벤트를 보내려는 시나리오를 테스트하고 있는데, 소비자가 흐름을 계속하기 위해 처리를 마칠 때를 관찰합니다. 즉 이벤트를 트리거 할 때 필요합니다. rxJava를 사용하여 소비자 프로세싱이 끝날 때까지 주 스레드를 차단해야합니다. Observable을 사용하여 관찰 가능한 결과를 기다리는 주 스레드를 잠그지 못했습니다. 내 생산 @Service pu

2열

1답변

봄 구름 흐름 RabbitMQ로 답장 메시지를 보내고 기다리는 방법?

나는 메시지를 보내기 위해 스프링 클라우드 스트림을 사용하려하지만, 나는 같은 방법으로 메시지를 보내고 반환하는 방법을 찾지 못한다. 나는 rabbitTemplate을 사용하는 것과 같다. RabbitTemplate template = new RabbitTemplate(cf); //configs template here... Object test = t

0열

1답변

Spring Cloud Stream - 여러 소스가 단일 스프링 부트 프로젝트입니다.

단일 SpringCloudStream 애플리케이션에 여러 소스를 가질 수 있습니까 (예 : 메인 클래스 및 3 개의 소스 클래스). 하나는 1.jdbc 폴러, 2.file 폴러, 또 다른 하나는 3.simple 페이로드 클래스입니다. DataFlowServer에서 스트림을 소스로 정의 할 때 상호 작용 방식과 흐름을 어떻게 정의할까요? 싱크가 세 번째 소스

0열

1답변

스프링 클라우드/스트림/스프링 부팅을위한 종속성 관리 및 릴리스 트라이얼

이것은 매우 기본적인 질문 일 수 있지만 Spring Boot 2 Mx, Spring Cloud Finchley.x 및 Spring Cloud Stream Elmhurst 사이의 관계를 보려 애 쓰고 있습니다. 엑스. 이 모든 버전이 서로 어떻게 연결되는지 설명하는 문서/추가 정보가 있습니까? 에 의해 발생 : java.lang.AbstractMethodE

0열

2답변

kafka 생산자/소비자가 다시 시작된 후 소비자가 메시지를 수신하지 않음

하나의 생산자 & 한 명의 생산자가 있습니다. & 한 파티션. 소비자/생산자 모두 스프링 부트 응용 프로그램입니다. 소비자 응용 프로그램은 내 로컬 컴퓨터에서 실행되며 생산자는 kafka & 사육사와 함께 원격 컴퓨터에서 실행됩니다. 개발하는 동안 일부 제작자 응용 프로그램을 재배포했습니다. 하지만 그 후 내 소비자는 어떤 메시지도받지 못합니다. 나는 소비

2열

1답변

Netflix Zuul 라우팅 URL은 항상 속성으로 하드 코딩해야합니까? 8090 : 대부분의 예에서 Zuul를 들어

우리는 zuul.routes.student.url=http://localhost:8090 그래서/학생 모든 URL이 로컬 호스트로 라우팅됩니다 URL- 라우팅을 제공합니다. 학생 모듈이 다른 영역에 있다고 가정하면 localhost : 8090 즉 유레카 (이 모듈이 등록 될 곳)에서 배포 된 위치를 얻을 수 있습니다. 또는 항상 속성으로 하드 코딩해야

1열

1답변

프로세서와 싱크 사이의 메시지 변환

처리 할 사람을 보내고 모든 오류를 수집하고 잭슨을 사용하여 직렬화하는 샘플 응용 프로그램을 만들려고합니다. 그러나 내 싱크는 프로세서에서 수신 한 메시지를 변환하려고 시도하지 않습니다. application/json 대신에 다른 contentType으로 메시지를받는 것처럼 보입니다. 이 기능을 사용하려면 어떻게해야합니까? 나는 봄 클라우드 Dalston.

1열

1답변

스프링 통합 애그리 게이터는 다음 메시지 내용을 기반으로합니다.

파일을 읽고 첫 번째 열을 기준으로 각 줄과 그룹 줄을 분할해야합니다. 첫 번째 열 값이 변경되면 이전 그룹을 해제해야합니다. Spring 통합 DSL에서이를 수행 할 수 있습니까? 여기 방법 파일보기 등이며, 분류 것 : 는 x 1 x 2 x 3 y 4 y 5 y 6 아웃 된 풋이 아무튼 이후로 X = 1, 2, 3 및 y = 4, 5, 6