如何使用 apache camel 轮询数据库答案

【问题标题】：How to poll database using apache camel如何使用 apache camel 轮询数据库
【发布时间】：2017-09-05 19:08:45
【问题描述】：

我想不断地从我的数据库中轮询一个表并推送到 Kafka。我正在为此使用 apache camel。

我的路线如下：-

from(timer:every 1 sec).
to(sql:select first 1000 * from myTable where id > myId).
to(updateMyId).
to(kafka:url).end()

问题是它不会在下一次迭代中使用更新的 myId。路由是静态的，如果最初 myId = 1，那么它会从 1 继续轮询。

如何动态更新 myId？

【问题讨论】：

【解决方案1】：

尝试这样。在更新时设置 myId 属性。

   from(timer:every 1 sec).
   to(sql:select first 1000 * from myTable where id >:#${property.myId}).
   to(updateMyId).
   to(kafka:url).end();

或将以下逻辑移至 bean。

   to(sql:select first 1000 * from myTable where id >:#${property.myId}).
   to(updateMyId).

【讨论】：