使用存储过程轮询数据库以获取数据库中的新行
Polling the database for a new rows in database using Stored Procedure
目前我正在执行存储过程并向Kafka发送消息。
现在我需要每 2 分钟或 5 分钟为新数据执行一次 SP。是否有针对 spring 启动的开箱即用的解决方案？
入站通道适配器有帮助吗？如果有任何示例或示例代码，我们将不胜感激。
参见Spring Integration Stored Procedure Inbound Channel Adapter。
Spring Integration Samples repo
的 intermediate 文件夹中有一些示例
目前我正在执行存储过程并向Kafka发送消息。
现在我需要每 2 分钟或 5 分钟为新数据执行一次 SP。是否有针对 spring 启动的开箱即用的解决方案？ 入站通道适配器有帮助吗？如果有任何示例或示例代码，我们将不胜感激。
参见Spring Integration Stored Procedure Inbound Channel Adapter。
Spring Integration Samples repo
的intermediate 文件夹中有一些示例