spring-xd

    0熱度

    1回答

    我已將Redis配置爲我的spring-xd安裝程序的MessageBus。當我的流失敗時,數據被推送到錯誤隊列。我正在嘗試讀取它們並將它們推回到目標隊列。但是我沒有看到我的Sink模塊接收數據。有些人可以幫助我瞭解我哪裏出錯了。 代碼片段。 public RedisTemplate<String, byte[]> redisTemplate(RedisConnectionFactory redi

    1熱度

    1回答

    我有一組XD作業模塊,都使用log4j日誌記錄。我最近升級到Spring XD 1.3.1,我的模塊不再記錄。 我已經嘗試將我的軟件包添加到xd-singlenode-logback.groovy配置文件。這沒有效果。 我創建了一個使用slf4j的虛擬模塊,它可以正確記錄。 我試圖找到關於log4j和logback兼容性的任何信息,但還沒有找到明確的答案。 我是否必須用slf4j切換log4j,或

    0熱度

    1回答

    我有一個自定義接收器模塊的流。當部署流時,模塊連接並從數據庫讀取屬性。我想刷新模塊屬性而不取消部署流,即如果在數據庫中進行更改,我應該能夠刷新屬性而不取消部署流。 任何想法或建議? 在此先感謝。

    0熱度

    1回答

    我有一個流定義爲流create --name foo --definition samplesource | sampleprocessor | samplesink --deploy。我使用Redis作爲MessageBus。 如果sampleprocessor或samplesink失敗,則xd會將失敗的消息推送到Redis:foo.n隊列中。我正在編寫代碼將錯誤隊列中的消息發送到foo.n.

    0熱度

    1回答

    我是springxd的新手,在傳入流下時遇到問題。 stream create foo2 --definition "jdbc --fixedDelay=1 --split=1 --driverClassName=oracle.jdbc.driver.OracleDriver --url=jdbc:mysql://localhost:3306/test --query='select * from

    0熱度

    1回答

    通配符SQL查詢我有一個用例在那裏我需要將數據從一個基於SQL的倉庫移到每天蒙戈。我們選擇SpringXD作爲這個ETL工作的工具。然而,我需要傳遞幾個狂放的梳理參數給我每天都在變化的查詢。我想知道是否有人知道,也無法向我提供樣品DSL爲通配符的參數傳遞給一個SQL SELECT查詢使用Spring XD時。

    0熱度

    1回答

    HortonWorks版本是2.4 SpringXd版本 - 1.3.1 我試圖運行從春天XD進口一sqoop工作。它給出了以下堆棧跟蹤。你能讓我知道這裏有什麼問題。 2016-05-16T11:29:54+0530 1.3.1.RELEASE INFO main tool.CodeGenTool - Beginning code generation 2016-05-16T11:29:54+0

    3熱度

    1回答

    我們正在探索各種編程/庫選項(在世界的Java方面)以實現更快的批處理並且能夠部署到雲上。我們遇到了Spring批處理/ XD /雲數據流。從對http://cloud.spring.io/spring-cloud-dataflow/文檔的快速回顧中,我們無法評估Spring雲數據流是否具備Spring批處理能夠提供的所有批處理功能。例如,以下是SPring批處理文檔(http://project

    1熱度

    1回答

    我正在爲我的springxd模塊編寫我自己的單元測試,(但是,我沒打算使用xd.test和xd.dirt)。 這是一個處理器模塊,我就是這樣做的測試是: 配置方面: ctx = new ClassPathXmlApplicationContext("config/spring-module.xml"); 得到inputDirectChannl和send(Message) input = ctx

    0熱度

    1回答

    我試圖按照本教程https://github.com/spring-projects/spring-xd-samples/tree/master/analytics-dashboard 我做了配置上modules.yml twitter: consumerKey: {your-consumer-key} consumerSecret: {your-consumer-secret