spring-cloud-stream

0열

1답변

Spring Cloud Dataflow를 사용하여 컨텐츠 기반 라우팅 및 필터링을 수행해야한다. 예 : 내 processor에 대한 입력이 String 인 경우. 문자열에 xyz이 있으면 내 Spring Cloud Stream에있는 구성 요소/단계 X에 전달해야합니다. 그렇지 않으면 구성/단계 Y 내 스트림으로 이동합니다. 나는 동일한 것을 달성하기 위해

0열

1답변

스프링 클라우드 스트림 앱 스타터가 10 초 후에 오류가 발생합니다. BinderException : 바인더를 초기화 할 수 없습니다.

트위터 소스 용 스프링 클라우드 스트림 앱을 실행 중입니다. docker 이미지가 성공적으로 시작되고 10 초 후에 org.apache.kafka.common.errors.TimeoutException을 throw하여 실패합니다. 60000 ms 후에 메타 데이터를 업데이트하지 못했습니다. 전체 스택 추적을 참조하십시오, 2017-11-16 06:41:33

0열

1답변

Spring Cloud Data Flow에서 Avro 구현하기

데이터베이스에서 레코드를 읽어들이는 Spring Cloud Dataflow 스트림을 구현하려고하는데,이를 Avro 스키마로 변환 한 다음이를 싱크 애플리케이션에서 사용하도록 전달하는 프로세서로 전달합니다. 데이터 원본을 SQL 데이터베이스에서 소스 응용 프로그램으로 전송하고 문제없이 카파 바인더를 통해 데이터를 전달합니다. 프로세서에서 싱크 응용 프로그램

1열

2답변

카프카 제작자 JSON 직렬화

카프카와 통합하기 위해 스프링 클라우드 스트림을 사용하려고합니다. 작성된 메시지는 Java POJO이고 예상대로 작동하지만 (메시지가 주제에 쓰여지고 소비자 응용 프로그램으로 읽을 수 있음) 메시지의 시작 부분에 알 수없는 문자가 추가되어 발생합니다 화제에서 메시지를 가라 앉히기 위하여 Kafka 연결을 통합 할 것을 시도 할 경우의 말썽. 이 메시지는 카

0열

1답변

스트림 재배포를위한 REST API

REST API를 사용하여 스트림을 재배포 할 수 있습니까? 현재 문서는 많은 정보를 제공하지 않습니다 - 나는 하나가 2 단계 과정으로이 작업을 실행해야합니다 추측하고 https://docs.spring.io/spring-cloud-dataflow/docs/current/reference/htmlsingle/#api-guide-resources-strea

0열

1답변

스프링 클라우드 버스, RenamingMQ 더 읽기 쉬운 방식으로

My Cleint가 2 개의 인스턴스를 가지고 있고 큐의 이름을 바꾸기 위해 스 니펫을 사용하고 있습니다. testExchange.testQueue가 생성되었습니다. 2 명의 고객, 즉 클라이언트 인스턴스를 볼 수 있지만 while/버스/새로 고침 하나의 인스턴스가 새로 고쳐지고있는 것을 볼 수 있습니다. /버스/새로 고침 모든 인스턴스가 새로 고쳐 져야하

0열

1답변

카프카를 사용하여 스프링 클라우드 스트림에 멱등 원 제작자를 어떻게 설정할 수 있습니까?

카프카 0.11에서 소개 된 멱등갑 제작자를 활용하고 싶습니다. 멱등 : 정확히-번 파티션 당 주문 의미에서 을 당 정확히 한 번만 의미를이 기능을 켜고 얻으려면 파티션 의미없는이 Confluent blog post에 따르면 새로운 속성은이를 지원하기 위해 추가되었다 중복, 데이터 손실 없음 및 순서대로 의미 - 제작자를 구성하여 "enable.idempo

0열

1답변

스프링 스키마 레지스트리 서버 및 MySQL

here과 같이 Spring Cloud Schema Registry Server를 실행하려고합니다. 다시 시작할 때까지 스키마를 유지하기를 원하기 때문에 MySQL을 사용하고 싶습니다. 하지만 응용 프로그램 시작시 다음 오류가 발생했습니다 : Table 'sr.schema_repository' doesn't exist. 내 자신이 필요한 테이블을 직접 만들

1열

1답변

봄 클라우드 버스는 AWS-운동성 <code>Spring Cloud Bus</code>의 문서에서

(https://github.com/spring-cloud/spring-cloud-bus)으로는 그 두 가장 일반적인 구현이기 때문에 버스 우선은, 카프카토끼 및 을 포함 같은 언급 하지만 Spring Cloud Stream은 매우 유연한 이며 바인더는 스프링 클라우드 버스와 함께 작동합니다. 우리는 토끼 나 카프카에 대한 또 다른 인프라를 유지할 수없는

0열

1답변

spring-stream은 "application/json"대신 "text/plain"content-type을 사용하여 메시지를 보냅니다.

페이로드에 json 객체가 포함되어 있으므로 content type application/json으로 응답을 생성하고 싶습니다. 하지만 ... (RabbitMQ 기준) 내 봄 스트림은 항상 아래 헤더 (페이로드가 정확하고 JSON 양식을 가지고)와 메시지를 생성하는 이유 알고하지 마십시오. = 캐릭터 셋 UTF-8, (view from rabbit ui)