时间戳

首页 > 解决方案 > Spring Batch Remote Partitioning with Kafka 作为中间件

spring-integration - Spring Batch Remote Partitioning with Kafka 作为中间件

问题描述

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

在所有文档中，我可以看到它支持 JMS 和 AMQP。谁能告诉我如何使用 Kafka 的远程分区作为中间件……如果有人也有工作示例，那将是一个很大的帮助？

标签： spring-integrationspring-batch

解决方案

spring-integration-kafka提供与用于 JMS 和 RabbitMQ 的端点类似的端点，因此将该文档中的概念应用于 kafka 应该不难。

最新spring-integration-kafka版本是 3.3.1（它正在移动到 5.4.0 中的核心 spring-integration 项目）。

推荐阅读