spring-cloud-stream

0열

1답변

RabbitMQ와 함께 Spring AMQP를 사용하는 기존 프로젝트에 Spring Cloud Stream을 추가하려고한다. 나는 다음과 같은 토끼 구성이 : 생산자 교환 이름 : producer.mail-sent.exchange 소비자 대기열 이름 : 생산자의 측면에서 consumer.mail-sent.queue I는 다음과 같이 구성 : spring:

0열

1답변

spring kafka, MessageDeliveryException : 채널에 메시지를 보내지 못했습니다.

저는 소스, 프로세스 및 싱크에 대한 문제로 고심하고 있습니다. 두 가지 프로젝트, 신청서가 있습니다. 하나는 소스 용이고 다른 하나는 프로세스 및 싱크 용입니다. 어떤 일이 일어 났는지 파악하기 위해 각 구성 요소를 공유하겠습니다. @EnableBinding(MultiProducerChannel.class) public class RealTimeData

0열

1답변

스프링 데이터 스트림 InboundChannelAdapter의 반환 유형이 다른 경우 동작이 다릅니다.

스프링 클라우드 스트림을 사용하고 있으며 반환 유형 MessageSource를 사용하는 InboundChannelAdapter를 사용할 때 문제가 발생하면 싱글 톤 클래스처럼 동작하며 매 1 초마다 실행됩니다. 동일한 데이터를 소비자에게 보내는 것. 또한 로거는 응용 프로그램 시작시 한 번만 인쇄합니다. @InboundChannelAdapter(value

1열

1답변

스프링 클라우드 스트림 시간 기반 자동 커밋을 사용하는 Kafka 소비자

카프카 바인더를 사용하는 Spring Cloud Stream 앱이있다. AckMode=BATCH을 기준으로 자동으로 오프셋을 커밋하는 것 같습니다 (디버깅 모드에서 문서화되어 나타나지 않아야합니다). 이로 인해 커밋 빈도가 중개인에게 상당한 오버 헤드가 발생합니다. 여기에 설명 된대로 enable.auto.commit: true auto.commit.in

1열

1답변

MessageCollector에서 문자열 대신 Object payload로 GenericMessage를 수신하는 방법

을 통해 MessageCollector을 사용하여 메시지를 보내고 받으려고합니다. 스트림 클라우드 용 원시 Java 직렬화를 사용할 때 모두 정상적으로 작동하지만 json으로 직렬화를 변경하면 MessageCollector가 SomeObject 페이로드 대신 string 페이로드로 GenericMessage를 반환합니다. 결과로서 주장 Message out

0열

1답변

카프카 바인더가있는 스프링 클라우드 스트림과 소스에서 데이터를 대기열에 넣는 방법

나는 kafka로 구름 구름을 봄으로써 그 개념에 대해 궁금해하는 초보자입니다. 내 응용 프로그램에서 소스가 kafka 바인더에 스트림을 보내면 데이터가 쌓이지 않습니다 ... 데이터 소스가 실제로 소비되지 않는 Kafka 소비자에서 작동하고 있음을 알 수 있습니다. 그러나 수신기에서 쌓인 데이터는 사용할 수 없습니다. (프로세서 수신기). 거의 실시간으로

1열

1답변

spring-cloud-stream-kafka-binder가 생성 한 spring-kafka를 사용하는 소비자 메시지

ConsumerSeekAware를 사용하여 카프카 주제에서 사용 가능한 마지막 메시지를 읽으려고합니다. 메시지 유형은 Avro 객체 목록입니다. 나는 그것을 성공적으로 할 수있다. 그러나 deserialization 중 실패 할 때. 메시지는 spring-cloud-stream-kafka 프레임 워크를 사용하여 생성되었습니다. 메시지의 콘텐츠 유형은 con

0열

2답변

봄 부팅 : 봄 클라우드 스트림 카프카 구현

그것은 클라우드 스트림 프로젝트에 특정 단 2 라이브러리와 매우 간단 구현 될 것으로 보인다하지만 프로젝트 java.lang.ClassNotFoundException: org.springframework.integration.support.converter.ConfigurableCompositeMessageConverter 모든 종속성을 얻고 것은 다음과

0열

1답변

봄 구름 데이터 흐름 파일을 찾을 수 없습니다

springboot에 마이크로 서비스를 만들었습니다. 리소스 폴더 아래에 폴더가 있고이 폴더 아래에 파일이 있습니다. i, e. 내가 그것을 파일을 작동하고이 springboot 응용 프로그램을 실행하고 때 resource mycustomfolder myfile.txt 내가 myfile @Value("${file-path}")

1열

1답변

스프링 클라우드 스트림 바인더 kstream-1.3.0 : 스프링이없는 IllegalAccessError 클라우드 스트림 바인더 kstream과 노력을 그 슈퍼

액세스 할 수 1.3.0.RELEASE 버전 의 pom.xml : <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLoc