使用Kafka作为中间件的Spring Batch远程分区

问题描述

我正在检查Spring批处理远程分区以从RDBMS源以及多分区的Kafka主题加载数据。我的问题是,我不能将RabbitMQ或JMS作为主节点和工作节点之间的中间节点,而只能将Kafka作为主节点和工作节点之间的通道。

在所有文档上,我都能看到它支持JMS和AMQP。 谁能告诉我如何在Kafka中间使用远程分区....如果有人也有工作示例,这将是很大的帮助?

解决方法

spring-integration-kafka为JMS和RabbitMQ提供了similar endpoints,因此将该文档中的概念应用于kafka并不困难。

spring-integration-kafka的最新版本是3.3.1(正在移至5.4.0的核心spring-integration项目)。