spring-cloud-stream

1열

1답변

@KafkaListener, @StreamListener 및 @ServiceActivator의 차이점은 무엇입니까?

스프링 부트와 아프로 스키마가있는 카프카를 사용하고 싶습니다. 하지만 나는 '이 3 명의 청취자의 차이점은 무엇입니까?'라고 물었습니다. 리스너를 만들 수있는 방법은 세 가지가 있습니다. - @KafkaListener, @StreamListener 또는 @ServiceActivator과 함께 메서드에 주석을 추가하십시오. 모두가 들어오는 이벤트를 듣고있는

2열

2답변

spring cloud stream app 시작 소스에서 생성 된 kafka 메시지에서 콘텐츠 유형 헤더를 제거하는 방법

@StreamListener (싱크) 이외의 사용자 정의 kafka 소비자를 사용하는 경우 트위터 소스의 경우 각 kafka 메시지에 대해 30 비트 헤더를 생성합니다. @StreamListener은 주석이 달린 메소드 (헤더 없음)에 정확하게 메시지를 보냅니다. 문제는 각 소스에 대해 헤더 크기가 다양하다는 것입니다. 맞춤 kafka 소비자를 사용하고 있

0열

1답변

Spring Cloud Stream을 사용하여 Confluent Schema Registry를 사용하여 Avro 메시지를 생성하고 소비하는 방법은 무엇입니까?

나는 Start Streaming with Kafka and Spring Cloud을 따라 예제를 실행할 수 있지만, 안타깝게도 합류 스키마 레지스트리를 사용하지 않습니다. 합류 스키마 레지스트리 부분을 Spring Cloud Stream reference guide으로 읽었지만 합류 3.0.0에서는 작동하지 않았고 합류 스키마 레지스트리를 사용하여 Avr

0열

1답변

스프링 클라우드 데이터 흐름 YARN : java.lang.NoSuchMethodError : javax.el.ExpressionFactory.newInstance()에서 실패 함 Ljavax/el/ExpressionFactory;

나는 spring-cloud-dataflow-server-yarn-dist-1.2.0.RELEASE 서버를 SPARK2-2.1.0.cloudera1-1.cdh5.7.0.p0.120904-el6.parcel과 함께 docker cloudera 컨테이너에서 실행하고있다. hadoop-2.6.0-cdh5.11.1. 내가 가져온 응용 프로그램 : app impor

0열

1답변

사용자 정의 프로세서, 싱크 및 프로듀서 헤드 코드 속성

메시지 채널을 바인딩하는 데 다음 사용자 지정 프로세서를 사용하고 있습니다. package test; import org.springframework.cloud.stream.annotation.Input; import org.springframework.cloud.stream.annotation.Output; import org.springframe

0열

1답변

재정의 된 RabbitSourceConfiguration (app starters)이 Spring Cloud Edgware와 작동하지 않습니다.

Spring Cloud Dalston.SR4/Spring Boot 1.5.9에서 Spring Cloud Edgware/Spring Boot 1.5.9로 Spring Cloud DataFlow 서비스 업그레이드를 테스트하고 있습니다. . 내 서비스 중 일부는 앱 시작 프로그램에서 소스 (또는 싱크) 구성 요소를 확장합니다. 나는 이것이 Spring Cloud

0열

1답변

스프링 클라우드 스트림 MessageChannel send() 항상 true를 반환합니다.

저는 Spring 클라우드 스트림을 사용하고 있으며 카프카 서버가 사라졌지만 MessageChannel send() 메소드가 항상 리턴 할 때 메시지를 저장하고 주제에 게시하려고합니다. Kafka/Zookeeper 서버가 중지 된 경우에도 마찬가지입니다. 누군가 도울 수 있습니까? application.yml 내용 UPDATE : spring: c

0열

1답변

Kafka 클라이언트 ID 속성 (봄 구름 스트림 사용)

Spring Cloud Stream을 사용하면 Kafka 클라이언트 ID 속성을 설정할 수있는 방법이 있습니까? 당연히 카프카 바인더를 사용하고 있습니다. 이것을 설정하는 서비스 중 일부가 복제 될 것이므로 인스턴스간에 ID를 고유하게 만들 수있는 방법이 있습니까? (Spring Kafka Consumer Client-Id configuration을 보면

0열

1답변

스프링 클라우드 스트림 kafka 바인더가 'bindingService'라는 이름의 빈을 생성하는 중 오류가 발생했습니다.

카프카 (Kafka) 주제의 이벤트를 수신하는 애플리케이션을 생성했으며 참조 용으로 GitHub (https://github.com/meta-magic/Kafka-Example)에서 공유했습니다. 봄 부팅 1.5.9.RELEASE 봄 구름 Edgware.RELEASE 의 pom.xml 응용 프로그램은 부팅 실패 <project xmlns="http://ma

0열

1답변

서비스가 다시 시작되면 Rabbitmq에서 메시지를 알리지 않습니다.

제 시스템에서는 이벤트를 보내고 받기 위해 spring-cloud-stream과 RabbitMQ를 사용합니다. 내 토끼 메신저를 실행 서비스 대답 최대 및 서비스 B 다운 있어요. 서비스 A은 서비스 B으로 이벤트를 보냅니다. 그런 다음 내 서비스 B을 표시하고 이제는 Rabbit이 이벤트를 속일 것이라고 기대하지만 아무런 반응이 없습니다. 올바른 행동입니