Spring批處理：從Kafka讀取數據並寫入文件

Question

我是Spring批處理新手。 我正在研究一個需要從Kafka讀取數據並從數據讀取中創建文件的需求。

經過一番研究，我瞭解到我需要使用Spring集成來連接和讀取來自Kafka的數據。

我已經構建了一個Spring批處理應用程序，我使用Spring Integration來連接和讀取來自Kafka的數據。

我被困在這一點上，關於如何將從卡夫卡讀取的數據傳遞給Spring批處理FlatFileItemWriter。

我想知道如果我採用從Kafka讀取數據（使用Spring Integration）的方法是正確的嗎？如果是，我如何將從卡夫卡讀取的數據傳遞給ItemWriter。

如果方法錯誤，那麼在Spring Batch中實現此需求的最佳方法是什麼？

感謝， 開放源代碼瀏覽器

Answer 1

Spring Batch的提供JmsItemReader。我希望你可以寫一個基於卡夫卡的ItemReader，它以類似的方式工作，將每條來自卡夫卡的消息作爲每個常規彈簧批處理範例的項目讀取。您可以在Github上查看JmsItemReader的代碼：https://github.com/spring-projects/spring-batch/blob/master/spring-batch-infrastructure/src/main/java/org/springframework/batch/item/jms/JmsItemReader.java