spring-xd

1熱度

1回答

1）spring-xd rabbitmq'requeue = false'選項不起作用。以下兩者設定結果相同。我被設置'requeue'選項爲'false'，但rabbitmq總是嘗試requeue（=重試）。這些選項之間有沒有優先權？是（maxAttempts優先級>排序優先級）??? module.*.consumer.requeue = true module.*.consumer

0熱度

1回答

如何在Spring-XD中讀取內聯屬性

我正在使用下面的流，我正在傳遞--properties值，如下所示。 stream create myFirstStream --definition "file --dir=C:\\\\input --outputType=text/plain | splitter --expression=payload.split('\\n') > sample-api --environment=DEV

1熱度

1回答

彈簧xd可以在紗線模式下使用外部火花簇嗎？

我在紗線模式下有一個火花簇，還有一些批處理和流式作業要運行。我發現spring xd可以處理批處理和流處理作業，並帶有嵌入的火花。我的問題是，彈簧xd可以在紗線模式下使用外部火花簇嗎？怎麼做？非常感謝。

0熱度

1回答

如何開發一個春季XD自定義作業從SFTP位置下載文件並將其保存在本地機器上

我試圖開發一個自定義作業，使用spring XD從SFTP位置下載文件。如果你能給我一些指導，這真的很有幫助，因爲我在這方面很新穎。

0熱度

1回答

春XD動態模塊的ClassLoader問題

據我們可以通過屬性文件利用屬性module.classloader動態加載模塊在創建時罐子的文檔： http://docs.spring.io/spring-xd/docs/1.3.1.RELEASE/reference/html/#module-class-loading 我花了兩天時間試圖測試這個功能。這是行不通的。選項module.classloader似乎被簡單地忽略我沒有找到名爲mod

1熱度

1回答

java.lang.NoClassDefFoundError：COM/SAP /康涅狄格州/ JCO/JCoException錯誤

java.lang.NoClassDefFoundError: com/sap/conn/jco/JCoException at testSAP.TestSAP.execute(TestSAP.java:41) ~[na:na] at org.springframework.batch.core.step.tasklet.TaskletStep$ChunkTransaction

0熱度

1回答

如何從spring-module.xml添加新頭文件

我需要從spring-module.xml文件添加頭文件。我得到以下響應 headers: file_name: sample.txt content_type: text/plain Payload: { "json":{ "type":"abcd","value":"1234" }} 在我需要添加一個字段，如標題「時間：時間戳」這些頭，我們應當只從彈簧module.xml增加。期

0熱度

1回答

Spring-XD spring應用程序的大數據

我是Spring-XD的新手，只有基本的想法，它有助於將大量數據存儲在hadoop中作爲文件。我想開發我的應用程序來保存使用Spring-XD到hadoop的套接字的數據。這可能嗎？如果是的話，任何人都可以指出我已經完成的一些例子嗎？請不要將我重定向到https://github.com/spring-projects/spring-xd。它不包含任何如何將文件寫入hadoop和hadoop

0熱度

1回答

Spring-xd批處理作業鎖定

我使用spring-xd通過批處理作業獲取數據。在4個集裝箱上並行運行了大量的作業。任何地方有10到40個工作。其中大部分完成不到一分鐘。我使用redis（不是rabbitmq）和mysql來存儲數據。 Spring-xd-batch爲作業/步驟統計使用不同的mysql-db，而我的應用程序爲了自己的目的使用不同的mysql-db。兩個mysql-dbs都在同一臺服務器上。所有4個容器和管理點指向

0熱度

1回答

Spring雲數據流聚合器示例

任何人都可以指出一些特定於String Cloud Data Flow（非Stream XD）的示例，介紹如何編寫分離器和聚合器？特別是非平凡的拆分和消息的加入。任何不重要的複雜流的例子。你如何定義一個在分離之後聚合消息的流，如果有路由器，並且爲生成的消息進行不同的處理，那麼以後如何聚合？ PS：對不起，我會根據需要澄清。謝謝！