spring-cloud-stream

0열

2답변

spring-cloud-stream을 추적 할 수 없습니다. spring-cloud-sleuth가있는 Listener

2 개의 매우 간단한 봄 구름 스트림 응용 프로그램이 있습니다. 메시지 생성자 인 Service3은 binder-kafka를 통해 소비자 인 Service4에 메시지를 보냅니다. 그리고 저는 스프링 클라우드 - 룰루를 사용하여 스팬을 추적합니다. Zipkin 서버에서는 Service3의 범위 만 사용할 수 있습니다. Service4에 대한 스팬이 표시되지

1열

1답변

Spring Cloud Stream은 Spring RestTemplate을 사용하여 RabbitMq에 게시 된 메시지를 구문 분석 할 수 없습니다.

spring-cloud-stream spring-boot app에 메시지를받는 데 문제가 있습니다. 메시지 엔진으로 rabbitMq를 사용하고 있습니다. Message Producer는 Spring RestTemplate을 사용하여 메시지를 전송하는 비 스프링 부팅 응용 프로그램입니다. 대기열 이름는 "audit.logging.rest" 소비자 응용 프로그

2열

2답변

스프링 클라우드 스트림 - 응용 프로그램 활성화 후 메시지 보내기

"봄철 구름 흐름"을 사용하여 간단한 메시지를 rabbitmq에게 보냅니다. 기본적으로 코드는 다음과 같습니다 : I 메시지 (단지 초 또는 몇)가 확인 작업을 전송하기 전에, 약간의 지연을 추가하는 경우, 그러나 org.springframework.messaging.MessageDeliveryException: Dispatcher has no subscr

0열

1답변

봄 구름 kafka 및 avro 직렬화 문제

나는 kafka에서 avro 메시지를 읽으려면 spring-cloud-stream-schema을 사용합니다. 나는 MessagesChannels에 입력 채널을 구성 : @Input("topicName1") SubscribableChannel fromInput1(); 내가 그와 같은 구성 파일이 :이 오류가 발생했습니다 @Configuration @E

0열

1답변

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

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

0열

3답변

spring-cloud-stream kafka 바인더에서 binary json 메시지를 수신 할 수있는 속성은 무엇입니까

카프카 항목에서 메시지를 소비하기 위해 spring-cloud-stream kafka 바인더를 사용하고 있습니다. 소스 시스템이 json 메시지를 ascii로 보냅니다. 내 소비자가 던지는 주제를 청취 할 때 o.s.c.s.b.k.KafkaMessageChannelBinder : Could not convert message: 7B22736.. 내 .y

0열

2답변

봄 부팅 및 봄 클라우드 스트림을 사용하여 카프카 제작자에서 avro 콘텐츠 유형을 설정하는 방법

봄 부팅, 봄 구름 스트림 스키마 레지스트리, kafka 바인더를 사용하여 avro 메시지 제작자, kafka 및 avro의 영사와 함께 작업 예제를 작성하려고합니다. 메시지를 소비하려고 할 때 오류가 발생합니다. ERROR 7059 --- [afka-listener-1] oscsbkKafkaMessageChannelBinder : contentType [

1열

1답변

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

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

0열

1답변

바인드 카프카가있는 스프링 클라우드 스트림

스프링 클라우드에 익숙하지 않고 kafka 브로커를 사용하는 스프링 클라우드 스트림에 대한 간단한 완전한 예제를 찾고 있습니다.

0열

1답변

봄 클라우드 스트림 RabbitMQ : delivery_mode에 게시 된 메시지는 1 republishToDlq = 나는 다음과 같은 구성으로, 생산자와 소비자 간단한 응용 프로그램이

진정한 = 때 spring: cloud: stream: bindings: input: binder: rabbit destination: dest group: gname rabbit: bindings: dest: consumer: