spring-xd

0熱度

1回答

當XD shell/XD-container意外退出並且作業仍處於部署狀態時，我多次觀察到此錯誤。當xd容器和xd-shell重新啓動時，它不允許我們用相同的名稱重新創建作業。但它在工作清單中也沒有看到。作爲解決方法，我們使用新名稱創建作業。有沒有這個問題的解決方案。我認爲這隻發生在Windows上的XD上，但它似乎也發生在Unix機箱上。 springXD job error

1熱度

1回答

SpringXD/Spring集成：使用不同版本的彈簧集成 - 卡夫卡對生產者和消費者

我有以下配置： Spring的集成 - 卡夫卡1.3.1.RELEASE 我有一個自定義卡夫卡水槽和一個自定義的卡夫卡源的配置我想有：我想仍然使用Spring-integration-kafka 1.3.1.RELEASE和我自定義的kafka-sink。我改變了我的卡夫卡型邏輯使用Spring的集成 - 卡夫卡2.1.0.RELEASE。我注意到實現消費者/生產者的方式與先前版本的Spri

0熱度

1回答

SpringXD：自動啓動=虛假不工作的卡夫卡消息驅動通道適配器

我使用SpringXD，我有以下配置：彈簧集成 - 卡夫卡2.1.0.RELEASE 卡夫卡客戶0.10.0.1 卡夫卡0.10.xx 彈簧XD-1.3.1.RELEASE 我在我的xml文件以下配置： <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans

0熱度

2回答

Spring XD無法找到RabbitMQ ConnectionFactory的類定義

我正在從xd-singlenode模式切換到分佈式，使用版本1.3.1-RELEASE。我在Docker容器中運行Spring XD，其中有Dockerfile similar to the one here。根據XD guide，如果我想使用RabbitMQ作爲我的數據傳輸，那麼我需要配置一個servers.yml文件。我有RabbitMQ在一個單獨的碼頭集裝箱中運行，並將這兩個集裝箱作爲碼頭

0熱度

1回答

方法調用：方法toObject（java.util.LinkedHashMap中）不能對org.springframework.integration.x.gemfire.JsonStringToObjectTransformer

我面對春季XD了以下問題和的GemFire nested exception is org.springframework.expression.spel.SpelEvaluationException: EL1004E:(pos 8): Method call: Method toObject(java.util.LinkedHashMap) cannot be found on org.spr

0熱度

1回答

彈簧數據流w/2源提供一個處理器/接收器

我正在尋找建立一個特定用例的Spring數據流流的建議。我的使用情況：我有2 RDBMS，我需要比較針對每個運行的查詢的結果。查詢應該大致同時運行。根據比較結果，我應該可以通過我創建的自定義電子郵件接收器應用程序發送電子郵件。我設想流圖看起來像這樣（對不起，油漆）：的問題是，日本自衛隊沒有，據我所知，允許流與2個源組成。在我看來，像這樣的事情應該是可能的，而不必將框架的限制推得太遠。我正在

0熱度

2回答

Gemfire CacheListenerAdapter實現ClassNotFoundException：org.apache.geode.pdx.internal.PdxType

當我試圖從gemfire實現CacheListenerAdapter時出現以下錯誤。 java.lang.ClassNotFoundException: org.apache.geode.pdx.internal.PdxType 我使用下面的代碼從獲得的GemFire緩存值。 import com.gemstone.gemfire.cache.Declarable; import com.gems

0熱度

1回答

從SpringXD遷移到Spring雲數據流

我們目前正在使用SpringXD將數據從各種數據源提取到接收器。由於Springxd預定可用性結束，我們希望遷移到Spring Cloud數據流。我們已經寫了幾個自定義模塊SpringXD。如何在SCDF中使用相同的模塊。在SCDF中使用這些變化需要做什麼修改。我們的羣集配置了kerberos，SCDF支持kerberized kafka和hadoop嗎？在運行時在紗線中使用服務器時是否有任

1熱度

1回答

springxd流使用HDFS數據集來保存avro數據無法更新kerberos票據

我創建了一個springxd流====>源JMS隊列 - >轉換 - 自定義Java處理器（XML到AVRO） - >接收器 - HDFS -Dataset。流工作正常，但24小時後，因爲它的連續連接，它無法更新kerberos身份驗證票並停止寫入HDFS。我們正在重新啓動這個流部署的容器，但仍然面臨問題並丟失消息，因爲它們甚至不會發送到redis錯誤隊列。我需要幫助 - 如果我們能夠續約流K

1熱度

2回答

彈簧XD Redis的水槽與收藏型MAP

我試着去實現Redis的特定於集合類型下沉= MAP stream create tTEST_GF_SINK --definition "trigger --initialDelay=0 --fixedDelay=1 --timeUnit=MINUTES --payload= 'new Date().toString()' --outputType=application/json |