spring-cloud-stream

0열

1답변

우리는 Spring XD에서 Kubernetes의 Spring 클라우드 데이터 플로우로 작업 및 스트림을 마이그레이션하는 중입니다. 스프링 클라우드 데이터 흐름에 대한 상용 지원이 있습니까? 모든 링크가 도움이됩니다.

0열

1답변

Spring 합치도 스키마 비 직렬화 예제

spring-kafka 2.0.0.Release를 사용하고 컨플릭트 스키마 레지스트리를 메시지를 비 직렬화하는 소스로 사용하는 소비자를 만들었습니까? 그렇다면 예제를 가르쳐 주시겠습니까? 내가 해결하려고하는 문제는 MFC에서 발생하는 이벤트를 스트림하는 kafka 연결 플랫폼에 Debezium CDC 커넥터가 있다는 것입니다. 이러한 이벤트를 변환하고 다시

0열

1답변

Spring Cloud Stream - 메시지 일괄 처리

일정한 간격으로 모든 일괄 처리 (10k 레코드를 한꺼번에 처리하는 대신)로 카프카 (Kafka) 주제에서 메시지 배치 (10000 메시지)를 가져 오려고합니다. 스프링 클라우드 스트림 프로세서에서이를 수행 할 수있는 방법이 있습니까? 그렇다면 어떤 스 니펫이나 제가 참조 할 수있는 예제가 있습니까? 감사

0열

1답변

스프링 부트 응용 프로그램 용 클라우드 파운드리의 응용 프로그램 수준 서비스 바인딩

다른 마이크로 서비스의 mysql 서비스 인스턴스로 내 스프링 부팅 응용 프로그램 (PCF에서 실행 중)을 바인딩해야합니다. 나는 응용 프로그램 수준 서비스 바인딩이 나를 도울 수 있다고 믿지만 여기서 스프링 클라우드 스트림 예제 만 얻을 수있다. https://docs.spring.io/spring-cloud-dataflow-admin-cloudfound

0열

1답변

소스도 싱크도 아닌 앱을 작성할 수 있습니까?

저는 모든 어플리케이션을 관리하기 위해 Spring Cloud Data Flow 서버를 사용하려고합니다. 또한, 나는 봄에 모든 새로운 있습니다. SFTP에서 파일을 읽고 S3에 쓰는 응용 프로그램을 작성하고 싶습니다. 파일은 매우 클 수 있으며 (각 500MB), 메시지 페이로드로 전달할 수 있습니다. 내가하는 모든 일이 SFTP에서 읽히고 S3에 쓰기

0열

1답변

Spring의 예제 코드가 필요함 aws S3 inBound와 Apache kafka가 아웃 바운드 인 경우

aws s3을 아웃 바운드로, Apache kafka를 아웃 바운드로 Spring 통합에 대한 예제가 필요하다. 나는 AWS의 S3에서 데이터를 읽고이를 분석하고 아파치 카프카 주제 여기

0열

1답변

kafka 바인더로 봄철 구름 스트림을 사용하여 메시지의 우선 순위를 지정하는 방법

TLDR : 같은 주제의 다른 사람들보다 먼저 긴급한 메시지를 처리하고 싶습니다. 더 설명 : 나는 몇 가지 작업을 위해 서로간에 이야기 할 수있는 카프카 - 바인더와 스프링 클라우드 스트림에 의존하는 많은 봄 microservices를 사용하여 상당히 큰 응용 프로그램에서 일하고 있어요 . 예약 된 작업으로 인해 많은 이벤트가 발생할 수 있습니다. 이러한

1열

1답변

스프링 클라우드 스트림 바인더 kafka가 Netty에서 실행되지 않습니다.

HTTP를 통해 계속되는 상태 변경을 제공하기 위해 Netty 위에 Kafka Steams와 Spring Webflux를 사용하여 스트리밍 엔진을 구축하고 싶습니다. 내가 내 Gradle을 파일 봄 부팅 응용 프로그램에 compile('org.springframework.cloud:spring-cloud-stream-binder-kafka') 의존성이있

0열

1답변

직렬 클라우드 스트림 (kafka)을 사용하여 직렬화로 protobuf를 사용하는 방법

저는 제작자와 소비자 마이크로 서비스간에 메시지를 교환하기 위해 스프링 클라우드 스트림 (kafka)을 사용하고 있습니다. 네이티브 java 직렬화와 데이터를 교환합니다. 스프링 클라우드 문서에 따라 JSON, AVRO 직렬화를 지원합니다. 어느 한 봄 클라우드 스트림에 protobuf 직렬화 (메시지 컨버터를) 시도가 ---------------- 나중에

0열

1답변

Spring Cloud Stream 카프카 바인더 : "IN_TRANSACTION 상태에서 IN_TRANSACTION 상태로의 변환이 잘못되었습니다."

Spring Cloud Streams + Kafka Binding을 사용하여 Apache Kafka에서 "정확히 하나의 전달"개념으로 PoC를 수행하려고합니다. Apache Kafka "kafka_2.11-1.0.0"을 설치하고 제작자에 "transactionIdPrefix"를 정의했습니다. 봄 카프카에서 트랜잭션을 사용하려면이 작업을 수행해야합니다.하지만