spring-cloud-stream

0열

1답변

Spring CloudDataflow에서 X 시간 이후에 스트림 배포를 취소하는 방법은 무엇입니까?

Spring CloudDataflow 서버에 스트림을 배포하고 누군가가 이전에 배포 취소하지 않으면 24 또는 48 시간 후에 자동으로 배포를 취소해야합니다. 아무에게도 내가 어디서부터 시작해야할지 모르므로 접근 방법을 알려 줄 수 있습니까? 도움이 필요합니다.

0열

1답변

springcloud에서 Kafka 소스/싱크가 누락되었습니다.

SpringCloud Dataflow에서 Kafka Source/Sink를 사용하고 싶습니다.하지만 spring-cloud-stream-app-starters에서 app-starters를 찾을 수 없습니다. 스프링 XD에서 사용할 수 있습니다. 왜 그들이 사라 졌는지 아는 사람 있습니까? 감사

1열

1답변

"condition paramter header"를 사용한 오류 새 릴리스의 @StreamListener Chelsea.RC1

이벤트 필터를 사용하여 응용 프로그램이 스프링 클라우드 스트림의 새 릴리스에서 사용 가능한 새로운 기능을 사용하여 사용하는 항목의 양을 줄이려고합니다. 첼시 .RC1). 그러나 올바른 헤더를 사용하여 메시지가 생성되고 있지만 큐의 메시지 내용을 검사 할 때 헤더에는 메시지가 포함되지 않고 페이로드가있는 본문 만 포함됩니다. public void sendEn

0열

1답변

봄 부팅

내가 spring.cloud.stream.kafka.binder.brokers = KAFKA_URL spring.cloud.stream.kafka.binder.zkNodes = ZKNODE_URL 와 소비자가 사용할 수없는 @EnableBinding 및 zkNodes를 사용하여 시작하는 데 실패 스프링 부팅 소비자 응용 프로그램을 실행하려고 시도하고 zkN

0열

1답변

원시 헤더가있는 null/tombstone 메시지 게시

카프카 (Cefka) 주제에서 문자열 키와 null 페이로드가있는 원시 데이터를 사용하는 Spring Cloud Stream Kafka 프로세서 응용 프로그램을 빌드하고 있습니다. String key와 null 페이로드 (Kafka 내의 묘비라고도 함)를 다른 주제로 생성하려고합니다. 메시지에 원시 헤더를 사용하려면 바이트 []를 출력해야하지만, Kafka

0열

1답변

스프링 클라우드 스트림에서의 일괄 처리 모드 및 사용자 정의 오류 처리

스프링 클라우드 스트림을 사용하기 전에 스프링 - 카프카 및 배치 소비 및 사용자 정의 오류 처리 지원을 사용했다. 이 스 니펫의 마지막 두 줄을 확인하십시오. 그러나 Spring Cloud Stream에서는이를 구성하는 방법을 찾을 수 없습니다. 나는 단지이 구성 속성을 찾을 수 있습니다 따라서 spring.cloud.stream.kafka.binding

0열

1답변

봄 구름 데이터 흐름에서 주제를 만드는 방법은 무엇입니까?

스트림 원본의 카프카에서 별도의 항목으로 내 원본의 마지막 읽기 레코드를 저장하려고합니다. 어떻게 스프링 클라우드 데이터 흐름 스트림 응용 프로그램을 통해 이것을 달성 할 수 있습니다. 모든 제안은 큰 도움이 될 것입니다.

0열

1답변

K8에서 배포하지만 로컬 배포에서 작업 할 때 스트림> 소스에서 UNKNOWN_TOPIC_OR_PARTITION을 발생시킵니다.

http://cloud.spring.io/spring-cloud-dataflow/에 설명 된 간단한 예제를 기반으로 "Hello, world"스프링 클라우드 데이터 흐름을 실행하려고합니다. 간단한 소스를 만들고 싱크대를 만들고 카프카를 사용하여 로컬 SCDF 서버에서 실행할 수 있습니다. 여기까지 모든 것이 정확합니다. 이제는 http://docs.spri

0열

2답변

Kubernetes/Spring Cloud 데이터 흐름 스트림> spring.cloud.stream.bindings.output.destination이 생성자에 의해 무시됩니다.

다음에 설명 된 간단한 예제를 기반으로 "Hello, world"스프링 클라우드 데이터 흐름 스트림을 실행하려고합니다. . 저는 간단한 소스를 만들고 싱크대를 만들고 카프카를 사용하여 로컬 SCDF 서버에서 실행할 수 있습니다. 그래서 여기까지 모든 것이 정확하고 SCDF에 의해 지정된 주제에서 메시지가 생성되고 소비됩니다. 이제는 http://docs.s

1열

1답변

String Cloud Stream - 재시도가 활성화 된 경우 메시지를 다시 표시하지 않고 강제로 문자를 쓰지 않으려면 어떻게해야합니까?

우리는 Spring Cloud Stream을 사용하고 있으며 소비자의 maxAttempts> 1을 사용하여 재 시도를 활성화했습니다. 메시지를 즉시 DLQ로 보내도록 즉, 큐잉을 우회하는 등의 방법이 있습니까? 메시지가 처리 될 때 소비자 리스너에 특별한 예외가 발생합니까?