spring-cloud-stream

3열

3답변

스프링 클라우드 스트림 소스 빈을 스프링 부트 애플리케이션에 작성하려고합니다. 메소드의 결과를 스트림으로 보냅니다 (기본 카프카 토픽은 흐름). 내가 본 스트림 샘플의 대부분은 @InboundChannelAdapter 주석을 사용하여 폴러를 사용하여 스트림으로 데이터를 보냅니다. 하지만 폴러를 사용하고 싶지는 않습니다. 폴러를 빈 배열로 설정하려고 시도했지

0열

1답변

Redis는 Spring Cloud Stream을위한 좋은 아이디어입니까? Kafka 또는 RabbitMQ를 사용해야합니까?

작은 스프링 클라우드 스트림 프로젝트 (http 소스 및 jdbc 싱크 (각각 3 개의 인스턴스) 만 사용)을 배포하고 있습니다. 예상로드는 초당 10 회입니다. 나는 redis를 사용하는 것을 생각하고 있었는데, 그 이유는 내가보기에 편하지 않았기 때문 이었지만, 최신 문서에서는 거의 모든 refereces가 kafka와 RabbitMQ에 있었기 때문에

0열

1답변

봄 구름 흐름 rabbitmq 소비자의 주제를 지정하십시오.

다른 주제의 메시지를 보내려는 중입니다. 듣고 자하는 주제에 대해 소비자를 구성하려고합니다. 제 아이디어는 단일 대상 "domainMessage"를 사용하고 사용자 지정 파티션 전략을 사용하는 것입니다. 나는 열거 형을 가지고 있는데, 그 값을 partitionKey로 사용하고 있는데, partitionStrategy는 단지 키를 반환 할 것이다. (키가

0열

2답변

Spring Cloud Stream에서 대기열을 만들지 않습니다.

RabbitMQ로 간단한 Spring Cloud Stream 애플리케이션을 구성하려고합니다. 내가 사용하는 코드는 대부분 spring-cloud-stream-samples에서 가져온 것입니다. 나는를 실행하면 fixedDelay: 5000 spring: cloud: stream: bindings: output:

1열

2답변

스프링 클라우드 스트림 앱인 Dispatcher에 'unknown.channel.name'채널에 대한 구독자가 없습니다.

spring-cloud-starter-stream-kafka를 테스트하고 있습니다. 아래 오류가 발생했습니다. org.springframework.messaging.MessageDeliveryException: Dispatcher has no subscribers for channel 'unknown.channel.name'.; nested exceptio

1열

2답변

메시징 소스 (예 : RabbitMQ, Kafka)에 이벤트 기반의 스프링 클라우드 작업 실행

저는 Learning of Spring 클라우드 태스크 및 SCDF에서 이렇게 묻습니다. 내가 이벤트 (예를 들어 메시지가 토끼 MQ에 게시)를 기반으로 내 SCT를 실행하기 위해 지팡이, 그래서 그것을 두 가지 방법으로 수행 할 수 있다고 생각 해요 : 이 소스를 작성하는 여론 조사 메시지 RabbitMQ에서 데이터를 스트리밍으로 보내면 스트림에서 데이터

2열

1답변

대상 시스템이 다운되었을 때 Spring Cloud Stream @StreamListener가 수신 대기하지 않는다

카프카에서 메시지를 가져 와서 대상 시스템을 호출하여 레거시 Oracle DB를 업데이트하는 애플리케이션이있다. 대상 시스템이 다운 된 경우 카프카 버스에 메시지를 남겨두고 주어진 시간 동안 처리하지 않는 시나리오를 활성화하고 싶습니다. Circuit-breaker Hystrix 기반 솔루션을 생각 중이었습니다.하지만 Spring Cloud Stream에서

0열

1답변

스프링 부트가없는 스프링 클라우드 스트림 응용 프로그램을 사용할 수 있습니까?

나는 spring-cloud-stream rabbitmq를 사용하지만 스프링 부트를 사용하지 않고 응용 프로그램을 작성하려고합니다. 내가 할 때 gradle dependencies 나는 구름 - 스트림 봄 부팅 모듈에 따라 달라집니다 참조하십시오. spring-boot-stream없이 spring-cloud-stream을 사용할 수 있습니까? 누군가가 어떤

1열

1답변

SpringCloudStream - 스프링 코어 버전에서 실패

스프링 부트를 사용하여 Spring Cloud Stream/App Starter로 게임을 시작했습니다. An invalid artifact was detected. This artifact might be in your project's POM, or it might have been included transitively during the resol

1열

1답변

봄 구름 데이터 흐름에서 Rabbitmq 바인더를 사용하는 방법

주어진 시간 간격에 따라 작업을 시작하는 스트림이 있습니다. 나는 토끼 바인더를 사용하고 싶지만 rabbitmq 브로커 속성을 제공하는 구문이 없습니다. 누군가 나를 도와주세요. Here is the steps and configuration I have. 1. Imported apps using: app import --uri http//bi