【发布时间】：2020-10-17 11:24:54
【问题描述】：
目前我正在执行一个存储过程并向 Kafka 发送消息。
现在我需要每 2 分钟或 5 分钟执行一次 SP 以获取新数据。Spring Boot 有什么开箱即用的解决方案吗？ 入站通道适配器可以提供帮助吗？如果可以，任何示例或示例代码将不胜感激。
【问题讨论】：
标签： spring spring-boot apache-kafka spring-kafka
【发布时间】：2020-10-17 11:24:54
【问题描述】：
请参阅Spring Integration Stored Procedure Inbound Channel Adapter。
Spring Integration Samples repo的intermediate文件夹中有一些样本
【讨论】：
-
我编辑了我的问题。我正在向 Kafka 而不是数据库发送消息。
-
?您的问题是关于轮询存储过程；您将使用 kafka 出站通道适配器将 SP 调用的结果发送到 Kafka。 Spring Integration 文档当前位于Spring for Apache Kafka documentation。它将在下一个版本中迁移到 Spring Integration。
-
。我只是怀疑为什么要使用 spring 集成.. 即消息通道。我可以简单地调用 SP（并使用计时器进行重复调用）并使用简单的 Spring kafka API 将数据发送到 Kafka。
-
当然；这是你的选择。任何一个都可以。如果您必须执行转换、聚合等，Spring Integration 可能更合适，并允许您分离关注点。