spring-xd

0熱度

1回答

試圖卡夫卡話題，因爲源時收到卡夫卡例外這是我如何創建流 stream create --definition ":myDestination > log" --name ingest_from_broker stream deploy ingest_from_broker --properties "spring.cloud.stream.bindings.input.consumer.hea

0熱度

1回答

如何通過Spring XD Sink獲取某些數據並將其存儲到多個表

我使用spring xd從原始表中獲取數據並對其進行處理，然後將其存儲到多個表中。我已經成功存儲到一張表中。我面臨的問題是如何使用Spring XD接收器jdbc將數據存儲到多個表中。目前我通過以下代碼創建流。它將從原始表（raw_device_data）中提取數據，並在處理後將其存儲到sleep_analysis表中。 stream create db --definition "sour

0熱度

1回答

在Springxd容器和UI中增加JVM堆空間

我們在生產中使用SpringXD。水槽是卡夫卡。如何設置/增加容器的JVM堆空間以及Admin-UI。什麼是參數設置和在哪裏？

0熱度

1回答

如何從文件名中刪除數字？

我使用Spring XD，我創建了以下流： stream create --name test --definition "time | hdfs --rollover=1B --directory=/xd/test --fileName=test --overwrite=true" --deploy 流生成許多文件。每個文件名都包含名稱和附加號碼，例如test-0.txt，test-1.tx

0熱度

1回答

如何使用spring xd jdbc接收器保存表列中的非頂級JSON元素？

我擁有的數據結構 { metadata: { eventId:string eventName: string ts: date time string . . . }, data:{ // complex event payload } } 我從一個消息總線獲取這些事件，並需要將信息寫入到關係表中有以下的列 EVENTID以下| e

0熱度

1回答

Spring Xd沒有可用於流的容器

我在分佈式模式下運行Spring XD。但是，當我調出一個容器時，管理節點會看到它，只部署一些而不是全部流。這裏是管理日誌 :11:41+0000 1.3.0.RELEASE INFO DeploymentSupervisor-0 zk.ContainerListener - Container arrived: Container{name='26c5cbfa-7f20-455c-a36c

1熱度

1回答

如何在Spring XD中從Kafka接收模塊獲取確認時手動提交Kafka源模塊上的偏移量？

在XD流中，消息通過源模塊從Kafka主題中消耗，然後發送到接收器Kafka模塊。開發自定義源和接收卡夫卡模塊的原因是，我只想從源模塊更新偏移量，只有當我從下游接收器模塊獲得成功發送消息的確認時。我正在使用Spring集成Kafka 2.0.1.RELEASE和Spring Kafka 1.0.3.RELEASE，並在Kafka 0.10.0.0環境中使用了主題。我曾嘗試以下：源模塊配置： @

0熱度

2回答

如何在Windows上運行Spring XD

下載Spring XD並在我的程序文件中提取文件夾後，我嘗試使用命令：xd-singlenode。這樣做之後，春天XD似乎只有一對夫婦秒工作，然後將下面的錯誤，這我無法解釋/解決它： C:\Program Files\spring-xd-1.2.0.RELEASE\xd\bin> xd-singlenode _____ __ _______ /___| (-) \ \/

0熱度

1回答

如何在不同的容器

做同樣的模塊實例之間春季XD負載平衡，我已經閱讀這篇文章，但它不是我的情況和不夠清晰： How does load balancing in Spring XD get done? 我有不同的情況下，一個由工作部署在不同容器中的相同子作業。我組合的工作計劃定期運行。我需要知道Spring XD如何選擇子作業實例來調用每個對組合作業的新請求。每隔X分鐘觸發一次流的相同問題。

0熱度

1回答

處理器輸入的Spring XD自定義類類型

我編寫了一個處理器模塊，獲取String有效負載並返回結果爲LogFileTuple類型。這個模塊運行良好。我寫了另一個模塊，獲取LogFileTuple作爲輸入。但部署流時：Source | Module1 | Module2 | Sink得到MessageDeliveryException。我transfor方法： public Event transform(LogFileTuple p