spring-cloud-stream

2열

1답변

Spring Cloud Streams가 메시지에 카프카 키를 설정하지 않았습니까?

이야기가 이와 같습니다. 나는 카프카 중개인과 ID로 키로 사용하려는 특정 객체 (내 주제를 통해 보내도록 jsonify)를 가지고 있습니다. 현재 'partitionKeyExtractorClass'구성을 사용하여 ID를 추출한 클래스를 키로 반환합니다. 나는이 주제에 대한 메시지를 탐색 할 때 내 메시지는 키가 null 말한다 보유 ConsumerReco

spring spring-boot apache-kafka spring-cloud spring-cloud-stream 2016-11-10

---

3열

1답변

Spring Cloud Stream + Quartz

내 프로젝트에 Spring Cloud Stream을 사용할 계획이다. Trigger source application starter가 내장되어 있습니다. 내가하고 싶은 일은 쿼츠 작업 스케줄러를 소스 앱으로 사용하는 것이다. 이것은 응용 프로그램에서 동적 작업 일정을 허용하는 것입니다. 이것을 달성하기위한 좋은 표본이 있습니까? 찾았습니다. spring i

spring-boot spring-integration spring-cloud-stream 2016-11-12

---

1열

1답변

프로덕션 환경에서 Spring Cloud Dataflow Local Server를 사용하는 것이 안전합니까?

우리는 로컬 시스템 환경에서 스프링 클라우드 데이터 흐름을 구현하여 매일 트랜잭션에 대한 스트림 및 작업 작업을 처리하려고합니다. PCF, Kubernetes, YARN 또는 Mesos를 사용하지 않으면 오케스트레이션을 위해 로컬 서버를 사용할 생각입니다. 개발에만 사용하는 것이 좋습니다. 프로덕션 환경에서 사용하는 데 문제가 있습니까?

spring-cloud-stream spring-cloud-dataflow spring-cloud-task 2016-11-12

---

0열

1답변

httpclient 프로세서`replyExpression` 변수

저는 스프링 클라우드 스트림 스타터로 파이프 라인을 구축 중이며 httpclient 프로세서가 하나의 단계입니다. 내 요구 사항은 원격 HTTP 서버를 호출하고 풍부하게 원본 메시지를 응답합니다. httpclient 프로세서는 원래 메시지의 특성을 전파 할 수 없으며 응답 본문을 기반으로 메시지 표현식 만 평가할 수 있습니다. httpclient 전에 메시

spring-cloud-stream spring-cloud-dataflow 2016-11-15

---

0열

2답변

봄 클라우드 스트림 - 카프카 바인더의 성능

나는 코드의 다음과 같은 간단한 조각이 있습니다 private int i = 0; @StreamListener(Sink.INPUT) public void processMessage(Message<?> message) { i++; } @Scheduled(fixedDelay=5000) private v

spring-cloud spring-cloud-stream spring-cloud-dataflow 2016-11-17

---

0열

2답변

kafka 0.8.2.2에 대한 스프링 지원이 있습니까?

카프카와 통합하기 위해 스프링 지원을 사용하고 싶습니다. 서버 버전은 0.8.2.2이지만 봄 프로젝트는 모두 새로운 카프카를 사용합니다. 심지어 spring-kafka-1.0.0은 kafka 0.9.0.1을 사용합니다. 나는 카프카 클라이언트가 이전 버전과 호환되지 않는다는 것을 읽었습니다. 그래서 질문은 : 오래된 카프카 버전에 대한 봄 지원이 있습니까

java spring apache-kafka spring-cloud-stream spring-kafka 2016-11-22

---

0열

1답변

Spring Cloud Dataflow - 메시지 보존 순서

소스, 프로세서 및 싱크와 같은 3 개의 애플리케이션이있는 스트림이 있다고 가정 해 보겠습니다. 원본에서받은 메시지의 순서를 유지해야합니다. A, B, C, D 메시지를 받으면 A, B, C, D로 싱크대로 보내야합니다. (나는 그들을 B, A, C, D로 보낼 수 없다). 각 응용 프로그램의 인스턴스가 하나뿐이면 모든 것이 순차적으로 실행되고 주문은 유지

spring cloudfoundry spring-cloud-stream spring-cloud-dataflow 2016-11-22

---

0열

1답변

Spring Cloud Stream Kafka : org.springframework.integration.MessageDispatchingException : Dispatcher에 구독자가 없습니다.

스프링클럽 스트림 Kafka 바인딩을 사용하여 지역 사육사 및 카프카 서버와 메시지를 보내고 받으려고합니다. Caused by: org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers at org.springframework.integration.d

spring apache-kafka spring-cloud-stream 2016-11-25

---

0열

1답변

spring-cloud-dataflow에서의 재귀

재귀 작업에 spring-cloud-dataflow (kubernetes)를 사용할 수 있습니까? 현재 결과에 따라 흐름의 새 인스턴스를 만들어야합니다 (재귀 적). 분산 된 작업 처리가 필요합니다. 1) message-source를 사용해야합니까? 내가 이해하지 못하면 dataflow는 자체 메시지 브로커 (rabbit, kafka)를 사용합니다. 다른

spring-cloud-stream spring-cloud-dataflow 2016-11-28

---

1열

1답변

여러 주제에 바인드하는 스프링 클라우드 스트림 카프카 소비자

여러 주제에 바인드 할 하나의 소비자 응용 프로그램 (하나의 JVM에서 실행 됨)을 구성하려고합니다. 소비자 응용 프로그램의 각 "소비"(내가 듣고 자하는 2 가지 주제가 있음) 메서드는 @StreamListener 주석으로 설정되고 특정 주제와 연결됩니다. 또한 다른 소비자 그룹의 각 소비자를 구성 할 것입니다. spring.cloud.stream.bin

java spring apache-kafka spring-cloud-stream 2016-11-29

---