spring-cloud-dataflow

1熱度

1回答

Spring Cloud Stream Kafka consumer with time based auto commit

我有一個使用Kafka活頁夾的Spring Cloud Stream應用程序。它似乎是基於AckMode=BATCH自動提交補償（必須在調試模式下找到它，因爲它沒有出現記錄）。這會給代理提交頻率帶來很大的開銷。我想無論是切換到使用本地卡夫卡自動提交，如： enable.auto.commit: true auto.commit.interval.ms: 5000 或切換到使用時配置與500

0熱度

1回答

如何更改stdout和stderr任務文件目錄？

在Linux中，任務執行的spring-cloud-dataflow本地服務器日誌是/ tmp/spring-cloud-dataflow- *。我需要在其他地方創建這些特定於任務的目錄，而不是/ tmp。例如而不是的/ tmp /彈簧雲dataflow- {數}/{任務名稱} - {數}/{任務名稱} - {} UUID 在有它：的/ opt/MYAPP /日誌/ spring-cloud

0熱度

1回答

Spring Cloud DataFlow：獲取有效載荷作爲列表<Map>

使用Spring Cloud DataFlow 1.3.0.M2與Spring Cloud Stream Starters Celsius.M1。我有兩個處理器。首先產生一個List<Map>，它應該被另一個消耗掉。這裏是簡化的代碼。 // Processor 1 @StreamListener(Processor.INPUT) @SendTo(Processor.OUTPUT) // N

1熱度

1回答

tasklaunchrequest變換忽略淨荷

0熱度

1回答

檢查春季雲流源和宿數據內容的方法

有沒有什麼辦法可以檢查春季雲數據流流源中有什麼數據（比如某個命名的目的地「mySource」）和宿（說「日誌」爲宿）？ e.g. dataflow:>stream create --name demo --definition ":mySource>log" 這裏有什麼在mySource和日誌 - 如何檢查？難道就像我必須檢查春天的雲數據流日誌某處得到任何線索，如果它有日誌？如果是這樣，Wi

1熱度

1回答

DLQ中沒有嵌入異常

我已經設置了包含kafka活頁夾的彈簧雲流。我還啓用了DLQ，並設置了headerMode捕獲異常消息，如here所述。但是，如果有例外情況，我只能在我的kafka主題中看到沒有例外情況的消息。我application.yml看起來像這樣 spring: application: name: Sample Stream cloud: stream:

1熱度

1回答

Spring雲任務不能在SCDF上啓動Kubernetes

我使用SCDF Kubernetes Server來部署Spring Cloud任務。當我啓動新加坡民防部隊Kubernetes服務器上春雲任務，我發現兩個奇怪的問題，請參見下面的細節：部署春季雲任務的時候，用參數的吊艙將在Kubernetes，see Pod picture生產。問題在於Pod的參數無法傳遞到Spring Cloud任務。當我啓動Spring Cloud Task時，如果我想

1熱度

1回答

如何縮放彈簧雲數據流量服務器

通常情況下，我們在其中一臺機器上運行彈簧雲數據流Jar，但如果在此期間我們在機器上創建了許多流量，並且服務器變得過載併成爲單個我們是否有一件事情可以在另一臺機器上運行Spring雲數據流服務器jar，並將這些數據流轉換爲這樣的數據流，以便我們可以避免任何此類故障，並使我們的完整系統更具彈性和強大。或者當我們在PCF /或雲代工廠部署完整系統時，擴展會自動發生。

0熱度

1回答

這是在春天的雲數據流中的錯誤：選項卡創建2個額外的kafka隊列和額外的橋樑彈簧啓動應用程序

對於我使用它創建額外的橋樑實例和兩個更多的kafka話題，小號 So - source p - processor s - sink 用例，用於創建數據爲新的記錄流流動 1）應如此=>取值 2），用於更新記錄流應如此=> p =>取值 DSL: demo1=so|p > :foo demo2=:demo1.so > :foo demo3=:foo > s 問題： 1）這裏的數據將

2熱度

1回答

如何配置Spring Batch的

春天數據流我有春天一批項目，我想在春天的雲數據流我爲能夠將其註冊在新加坡民防部隊，但在發射任務我的作業沒有運行，以下配置它是我的配置文件 @SpringBootApplication @EnableBatchProcessing @EnableTask public class BatchApplication { /*@Autowired BatchCommandLineRunner