spring-xd

3熱度

1回答

閱讀文件，我想讀從AWS S3文件，並與Spring Batch的處理它：可以在春天Itemreader處理這項任務？如果是這樣，我如何憑據傳遞到S3客戶端和配置我的Spring XML來讀取一個或多個文件 <bean id="itemReader" class=""org.springframework.batch.item.file.FlatFileItemReader""> <

0熱度

1回答

使用Ambari插件升級Spring XD的步驟是什麼？

我使用Ambari插件在HDP 2.2上成功安裝了Spring XD 1.2.0 RC1。現在Spring XD 1.2.0 GA已經發布，我該如何去升級我的安裝？

1熱度

2回答

Gemfire pdxInstance數據類型

我正在使用以下順序將pdxInstance寫入GemFire：rabbitmq => springxd => gemfire。如果我將此JSON放入rabbitmq {'ID':11,'value':5},value在GemFire中顯示爲字節值。如果我把{'ID':11,'value':500}，value作爲一個詞出現，如果我把{'ID':11,'value':50000}它看起來是一個整數

0熱度

1回答

春天XD文件作爲源數據流的情況下不工作

我試圖使用spring xd從文件的讀取源，並把數據在jdbc，我嘗試了工作批量filejdbc使用下列內容： xd:>job create csvtojdbc --definition "filejdbc --resources=file:\Batch\sourcecsv.csv --names=id,name,gender --tableName=csvfiletomysql_tbl2 --u

0熱度

1回答

Spring XD facebook數據提取

有沒有辦法使用Spring XD提取Facebook數據？我現在可以使用Graph api，Json，Java程序提取Facebook數據，但問題是如果我可以整合這個以便通過Spring XD自動執行。

2熱度

1回答

spring-integration-kafka註釋支持和示例

雖然對於Spring來說是新的，但我通常只能使用註釋很好地開始Spring項目。官方示例使用xml，而不提及它們將放置在哪裏等。是否有從kafka主題閱讀的任何示例項目？最好通過使用註釋來設置kafka配置屬性。

1熱度

1回答

帶過濾器的Spring-xd水龍頭？

我有一個不同類型文本記錄的流「myStream」，比如說「A」，「B」，「C」等......每種類型的記錄需要不同的處理。我想爲每種類型的「myStream」創建多個tap：tapA，tapB，tapC等。但似乎tap沒有任何過濾功能。這是真的還是我錯過了什麼？有沒有更好的方法來完成這一點？

0熱度

1回答

Spring-xd接收器：文件翻轉支持

我發現request for sink:file rollover support，但現在似乎閒置了一年多。將這個添加到spring-xd的機會有多大？同時，有沒有辦法在不安裝/部署HDFS的情況下完成此任務？

0熱度

1回答

Spring-XD處理中的錯誤：KafkaMessage，MessageDispatchingException：調度程序沒有訂閱者

我正在使用Spring-XD從kafka讀取主題，使用spark-streaming-processor過濾數據並將數據陷入spark。我用於部署流的命令是： stream create spark-streaming-word-count --definition "kafka --zkconnect=localhost:2181 --topic=log-stream | java-word-

2熱度

1回答

在Spring XD源代碼模塊中返回MongoDB中的最後一個值查詢

我希望能夠創建一個查詢/查詢表達式，我可以在SprinXD MongoDB源模塊中使用該查詢/查詢表達式來僅返回已插入的最後一個文檔。看來，最大的消息每民意調查沒有做的伎倆（paginated data with the help of mongo inbound adapter in spring integration）我知道如何與agreggation，findOne（），限制（）等，但