如何解决使用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项目)。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。