spring-cloud-stream

-1熱度

1回答

最初配置以下從application.properties屬性： spring.cloud.stream.defaultBinder：XXXXX spring.cloud.stream.binders.XXXXX.type：兔 spring.cloud.stream.binders.XXXXX.environment .spring.rabbitmq.addresses： spring.cloud

0熱度

1回答

如何獲得Spring Cloud Stream App Starter httpclient處理器將api響應的錯誤消息發送到日誌接收器？

當我檢查我的httpclient處理器的標準輸出日誌時，發現我發出請求時收到422響應。與響應一起發送的實際錯誤消息已丟失，或至少我不知道如何解決。是否有可能發送JSON響應到日誌接收器，以便我可以解決我的請求？

0熱度

1回答

Spring Cloud Stream Producer在使用Spring Kafka Consumer時添加「垃圾」字符

我們的微服務正在使用JDK 8，Spring Cloud Stream API和Spring Boot 1.5.2.RELEASE在Kafka Queue上生成消息。對於消費者API，我們使用的是Spring Kafka 1.1.2.RELEASE，特別是@KafkaListener。消息類型的應用程序JSON 我們注意到，消費者有附加到附近的「的contentType」，該消息的一些垃圾字符被如

0熱度

1回答

用於RabbitMQ隊列的Pollable StreamListener或MessageSource

我有Spring Cloud Stream Rabbit項目，在流程中發生錯誤時向兔子交換機發送消息errorEx。我想定期（5分鐘一次）從隊列中偵聽並處理它。有沒有什麼辦法可以讓Pollable @StreamListener？或者我可以配置一個rabbitMQ org.springframework.integration.core.MessageSource，所以我可以用Poller構

0熱度

1回答

無法在春季雲流kafka中設置kafka屬性

我正在使用春季雲流kafka。我已將kafka的屬性設置如下： spring.cloud.stream.bindings.output.contentType=application/x-java-object;type=com.example.demo.KafkaApplication.Message eureka.client.service-url.default-zone=http://

0熱度

1回答

使用Spring Cloud Stream和RabbitMq處理異常

在Spring Cloud Stream中找到有關異常處理的任何信息時遇到問題。我知道有errorChannel這是假設處理異常，但我不知道如何使用它。任何人都可以給我任何樣品嗎？目前，當我發送一個事件到我的接收器（@StreamListener(target = Sink.SAMPLE)），並在處理MessageHandlingException將發生時，我只獲取日誌，並沒有機制來通知我的來源。

1熱度

1回答

Spring Cloud Stream和RabbitMQ運行狀況檢查

我有一個簡單的Spring Boot應用程序，使用Spring Cloud Stream Rabbit和Eureka Discovery Client。該應用程序與Eureka Server一起運行良好，並且通過RabbitMQ的消息傳遞也正常運行。但是，如果我旋轉了一個春天啓動管理服務器，應用程序啓動時登錄健康檢查故障： 2017-06-21 19:47:57.352 INFO 11416 --

1熱度

1回答

本地數據流服務器上的Spring雲流聚合應用程序

我正在嘗試創建與數據流Web服務器一起運行的Spring Cloud Stream Aggregate應用程序，以便能夠通過Web UI管理應用程序。應用亞軍類： @SpringBootApplication public class Runner { public static void main(String[] args) { new AggregateApplicatio

0熱度

1回答

使用在春季雲流的目的，具有RabbitMQ的

我使用的RabbitMQ在雲流中間件，當我配置application.yml spring: cloud: stream: bindings: usertest: #channelName content-type: application/json group: testGroup destination:

0熱度

1回答

無法過濾使用Spring雲流條件屬性接收到的消息流@StreamListener註釋

我試圖創建一個基於事件的系統，使用Apache Kafka作爲消息系統和Spring雲流Kafka進行通信。我已經如下書面我的接收器類的方法， @StreamListener(target = Sink.INPUT, condition = "headers['eventType']=='EmployeeCreatedEvent'") public void handleEmploye