spring-xd

1熱度

1回答

我在使用spring-xd將hdfs作爲接收器部署流時出現以下異常。創建名稱爲bean的錯誤'hadoopConf iguration':Invocation of init method failed; nested exception is java.lang.NoClassDefFoundError: org/apache/hadoop/mapred/JobConf 我有我的spring-

0熱度

1回答

自定義Python模塊在模塊中引發異常時無法重新執行

我定製了一個處理器Python模塊，RabbitMQ作爲源，Python模塊在python模塊中引發異常時無法重新執行。這條巨蟒模塊，其連接到elasticsearch，當ES下跌，這引發異常XD總是從RabbitMQ的得到消息，並拋出例外，甚至elasticsearch服務再次可用。 2015-04-23 19:27:52,336 1.1.1.RELEASE ERROR SimpleAsync

0熱度

1回答

用於日誌管理的Spring Xd

我想使用spring xd來獲取一些日誌文件並將這些文件索引到Apache solr中以供後續搜索使用。爲了使用「文件」源，該目錄必須是本地到運行spring xd的機器。爲了收集日誌數據並將這些日誌發送到中央服務器進行索引，是否將Spring xd用作所有應用程序服務器上運行的代理的正確方法？它有道理嗎？在此先感謝

0熱度

2回答

春XD的GemFire下沉，關鍵一流，價值類參數

有沒有辦法在春XD使用，關鍵一流和值一流參數爲的GemFire沉？關於文檔，我只能使用keyExpression但沒有關於它的類類型。同樣的關鍵類。我有這樣的命令，以使的GemFire， put --key-class = java.lang.String --value-class = Employee --key = ('id': '998') --value = ('id': 186,

0熱度

1回答

在自定義處理器模塊內部過濾數據？

我正在編寫一個使用變壓器類的定製處理器模塊，，對於某些輸入，我不希望變壓器生成任何輸出，我該怎麼做？我試圖在transform（）方法中返回null，但這使得Spring-xd運行時生成異常。而我不想在流定義中使用過濾器，因爲這對我來說會過度。有什麼建議嗎？

1熱度

1回答

Spring XD源代碼失敗處理

我有一個流，其中包含一個模塊，其行爲與source：file模塊的行爲類似，只是使用redisMetaDataStore和Spring Integration的FileSystemPersistentAcceptOnceFileListFilter只檢測一次文件，以便模塊可以記住哪些文件已經在容器重啓之間被讀取。文件persisting.xml <beans:bean id="redisMeta

0熱度

1回答

爲Oracle配置Spring-xd

我試圖在分佈式模式下運行spring-xd並且必須使用Oracle DB。當我開始XD-管理，它失敗，出現以下錯誤： Caused by: java.io.FileNotFoundException: class path resource [org/springframework/xd/batch/schema/registry-schema-oracle.sql] cannot be open

0熱度

1回答

如何讓kafka在spring xd運行時使用http流數據？

是否有可能在春季xd運行時將kafka源模塊用作處理器模塊？任何代碼示例？我想實現這樣的事情：http（xd source）| kafka源（xd處理器）| kafka消費者（xd接收器）我正在嘗試這樣做，因爲我有通過http傳輸的流數據，我想用kafka消息總線進行管理。我的流定義是這樣的： stream create kafkaSourceTest --definition "http

0熱度

1回答

有沒有從Spring XD收集指標到Graphite的方法？

在閱讀Spring XD的文檔時，我看到它有一個收集度量標準的模型。但是當我查看代碼時，我已經看到這是一個Spring XD的自定義實現。在項目依賴關係中，codahale的度量指標並不那麼重要。不，如果能夠將記者添加到收集的度量標準中（如同時位於Spring XD庫中的Graphite記者）將會非常有用。但是我無法在文檔中找到任何這方面的信息，這可能或應該如何完成。有人有提示如何去做，或

1熱度

1回答

如何配置並行作業執行次數

看起來像並行作業執行次數是有限的。我的觀察是，Spring XD運行時（單節點模式）最多同時執行10個作業。我已經創建了15個工作（wait1，wait2，...），只需等待一分鐘，然後立即執行它們（工作啓動wait1，工作啓動wait2，...）。我有很多因爲等待其他服務器響應而阻塞的作業，所以我想增加執行作業的數量。在文檔中找不到任何東西，並且在servers.yml中找不到任何東西