spring-xd

1熱度

1回答

我們爲Spring XD編寫了一個自定義Http客戶端，並計劃使用此自定義處理器來調用不同的API。但是，我們有一種情況需要根據有效負載調用兩個不同的API。除了使用動態路由器（寫入指定通道）有一種方法可以動態地爲http客戶端調用URL嗎？這是當前的配置。 <header-filter input-channel="input" output-channel="inputX" head

2熱度

1回答

在Header中將HeaderInformation作爲JSONObject傳遞給Spring-XD

我將數據作爲JSONObject傳遞爲Header和下一個模塊/處理器中的字符串，使用下面的代碼，但將數據作爲「[email protected]」接收到的下一個模塊中。無法將其轉換回JSONObject作爲字符串。 messageOut = MessageBuilder.withPayload(message-payload).copyHeaders(payload.getHeaders()).

1熱度

1回答

如何使用Spring XD自動創建兔子隊列源代碼

我的流定義中有Spring XD Rabbit源代碼，但當它正在偵聽的隊列尚未創建時，它將失敗。當我使用Spring集成啓動時，我可以在我的JavaConfig中執行此操作。我流定義：流創建--name HOLA_Q --definition「兔--requeue =假|我-自己的處理器|空」 --deploy 我在春天用兔管理員嘗試-module.xml位於my-own-processor中

3熱度

1回答

SpringXD - Gemfire中的錯誤接收器

我試圖在springXD中設置一個流。 gemfire安裝在10.99.40.60機器上，springXD安裝在我的LOCAL虛擬機中。 xd:>stream create --name gemfiredemo --definition "http --port=9090 | gemfire-server --host=10.99.40.60--port=10334 --useLocator=t

1熱度

2回答

Spring雲數據流中是否存在另一個運行時模型，然後是one-jvm-per-module-instance？

目前，我們使用Spring XD與許多流（和模塊）進行數據攝取。不幸的是，Spring XD已停產，我們不得不尋找替代品。因此，我們看看Spring Cloud Data Flow，因爲我們希望通過shell動態部署流。不幸的是，簡單的流"http | log"花了1,6 GB RAM。然後，我推出了第二遍，都流了3.2 GB RAM ... 通常我真的很同意，通過工藝縮放是一件好事..但要做到

3熱度

1回答

創建簡單的彈簧XD流時出現文件路徑問題

我在分佈式YARN setup.I上運行spring XD，我使用的hortonworks數據平臺有6個數據節點和1個名稱節點。並使用名稱節點作爲客戶端節點。我已經從名稱節點調用xd Shell，管理員和容器正在數據節點上運行。所以，當我創建如下春天XD流定義： xd> stream create --name filetest --definition "file | log" --deploy

0熱度

1回答

在Spring XD，如何可自動故障一個流時拋出內部模塊

任何異常在Spring XD，我正在與多個模塊流如下所示 XD>流創建主流--definition「Kafka-來源|處理器模塊1 |處理器模塊2 |模塊接收器「 - 部署我在上述管道的模塊2代碼中拋出了runtimeException（），並期望在拋出異常後流失敗，但是流不失敗。我試圖檢查流列表命令其顯示流狀態爲「部署」。任何人都可以幫助我如何在運行時如果在任何一個模塊發生任何異常時失敗流

1熱度

1回答

增加主題支持隊列的併發性：通道

我在SpringXD 1.3.0上測試。將消息複製到不同的接收器。我的配置是由RabbitMQ支持的三節點羣集作爲消息總線。我的測試是這樣的：首例 stream create sourceToDuplicate --definition "trigger --fixedDelay=1 --timeUnit=MILLISECONDS --payload='test' > topic:test"

1熱度

1回答

彈簧集成文件分割器發送文件標記作爲有效載荷

我有彈簧xd源模塊，它將逐行分割文本文件。我想查看文件名並計算文件中的行數，因此我正在使用文件分割器和filemarkers.But問題是如果我有文件中的一個記錄文件計數作爲有效負載和3行即將到來（1記錄+2從文件標記開始和結束）因此，我期待有效載荷作爲文件記錄的處理器得到一些文件標記我。如何可以使它們作爲標題，而不是出現在有效載荷 <?xml version="1.0" encoding="UT

1熱度

1回答

處理xd文件流之前的健康檢查

我從s3拉取文件並使用spring xd處理它們。我有一個處理器的http客戶端組件，我做了一些RESTful請求。現在這種方法的問題是，如果我的web服務是關閉文件獲取在兔子mq傳輸積累。因此，在從s3拉個人文件之前我想做一個健康檢查在我的休息服務。我可以如何解決這個我的配置文件看起來像這樣。 <?xml version="1.0" encoding="UTF-8"?> <beans