spring-cloud-stream

0熱度

1回答

檢查春季雲流源和宿數據內容的方法

有沒有什麼辦法可以檢查春季雲數據流流源中有什麼數據（比如某個命名的目的地「mySource」）和宿（說「日誌」爲宿）？ e.g. dataflow:>stream create --name demo --definition ":mySource>log" 這裏有什麼在mySource和日誌 - 如何檢查？ 難道就像我必須檢查春天的雲數據流日誌某處得到任何線索，如果它有日誌？如果是這樣，Wi

spring-cloud spring-cloud-stream spring-cloud-dataflow 2017-10-13

---

1熱度

1回答

DLQ中沒有嵌入異常

我已經設置了包含kafka活頁夾的彈簧雲流。我還啓用了DLQ，並設置了headerMode捕獲異常消息，如here所述。但是，如果有例外情況，我只能在我的kafka主題中看到沒有例外情況的消息。我application.yml看起來像這樣 spring: application: name: Sample Stream cloud: stream:

spring-cloud-stream spring-cloud-dataflow spring-kafka 2017-10-13

---

0熱度

1回答

沒有java接口的Spring Cloud消息通道

我有一個Spring雲流應用程序。它接收來自20個AMQ隊列的消息。並使用綁定通道將這些發佈到20個Kafka主題。對於kafka出站通道，有一個接口，每個通道都配置如 @OUTOUT MessageChannel channel01（）;問題是我每次添加一個主題時，都必須將其添加到此界面中並重新部署應用程序。 有沒有什麼辦法可以在不改變這個接口的情況下在yml文件中指定新創建的主題？所以我的應用

spring-cloud-stream 2017-10-14

---

0熱度

1回答

spring-cloud-stream-kafka：爲什麼不KafkaBinderHealthIndicator緩存消費者

什麼原因沒有緩存KafkaConsumer s在KafkaBinderHealthIndicator？後者是在KafkaBinderConfiguration autoconfig中創建的一個bean，那麼爲什麼不重用消費者？ 最有可能不是問題，但感覺不對，因爲我們的堆棧中的每個節點每分鐘被顯示器查詢/health一分鐘12次。

java spring-boot spring-cloud-stream spring-kafka 2017-10-16

---

1熱度

1回答

Spring雲流自動重新連接到兔子MQ

我有一個連接到RabbitMQ服務器的Spring Cloud Stream應用程序。我們在Rabbit MQ中使用rabbitmq-auth-backend-uaa插件，但這不是問題。 該插件會檢查在創建與Rabbit MQ的連接時作爲用戶名發送的oAuth2.0 JWT令牌。 要做到這一點，我有這樣的代碼在我的Spring應用程序： @Bean @Primary ConnectionFac

spring rabbitmq spring-amqp spring-cloud-stream spring-rabbit 2017-10-17

---

0熱度

1回答

異步寫入春雲卡夫卡流

我希望異步寫入春雲卡夫卡流。例如 Class SomeClass{ @StreamLister(Processor.INPUT) public void receiveEvents(String e){ class ThreadExecutor implements Runnable { private String message; public Thre

spring-cloud-stream spring-kafka 2017-10-18

---

1熱度

1回答

使用spring雲流向錯誤通道發送錯誤消息

我正在使用spring-cloud-stream：1.3.0.RELEASE，spring-cloud-stream-binder-kafka：1.3.0.RELEASE進行spring引導應用程序的工作。我使用spring integration dsl來分割文件和beanio中的行，將行轉換爲json，要求將成功的json消息寫入kafka主題，並將錯誤消息寫入不同的kafka主題。以下是ap

spring-integration spring-cloud-stream spring-kafka 2017-10-18

---

0熱度

1回答

春雲流Kafka粘結劑：「嘗試從狀態IN_TRANSACTION到狀態IN_TRANSACTION的無效轉換」

我正在嘗試使用Spring雲流+ Kafka綁定對Apache Kafka進行「恰好一個交付」概念的一些PoC。 我安裝了Apache Kafka「kafka_2.11-1.0.0」，並在生產者中定義了「transactionIdPrefix」，我知道這是我在Spring Kafka中啓用事務所需要做的唯一事情，但是當我這樣做時，運行簡單源代碼&在同一個應用程序中接收器綁定，我看到一些消息在消費者

apache-kafka spring-cloud-stream spring-kafka 2017-12-27

---

0熱度

1回答

spring-cloud-stream-kafka配置：instanceCount＆instanceIndex

運行spring-boot 1.5.7.RELEASE程序使用spring-cloud Dalston.SR4。 曾爲自己通過雲流documentation，特別是關於卡夫卡粘合劑的使用，但我仍不清楚在一些配置方面： 難道我們真的需要設置spring.cloud.stream.{instanceCount,instanceIndex}當我們從卡夫卡經紀人消耗？我不明白爲什麼會這麼做，因爲設置了sp

java spring-boot spring-cloud-stream spring-kafka 2017-10-13

---

0熱度

1回答

如何爲spring-cloud-starter-bus-kafka提供SSL配置1.2.0.RELEASE

我使用Spring Boot 1.5.6.RELEASE，Spring Cloud Config 1.3.2.RELEASE和Spring Cloud Starter Bus（Kafka ）1.2.0.RELEASE，而Kafka版本是0.10.1.1。我試圖將其配置爲使用兩個啓用了SSL的經紀人，但我最終得到看起來像這樣的警告信息的重複序列（每個經紀人）： Bootstrap broker br

spring-cloud spring-cloud-stream spring-cloud-config spring-kafka spring-cloud-bus 2017-10-18

---