根据汇合文档，当我们使用查询模式时，我们必须进行偏移管理。根据我的理解，我们需要跟踪上次更新的时间戳，并在每次重新启动程序时将其传递给where子句。任何人都可以确认理解是否正确？提前感谢您的帮助！
您可以同时执行这两项操作 - 除了查询之外，您仍可以设置时间戳和递增模式。它只是添加一个基于timestamp.column.name和/或incrementing.column.name字段的where语句。如果查询需要where语句，您甚至可以使用子查询
例如，您可以将查询设置为：select * from（从树中选择apple = color = green）作为子查询
将timestamp.column.name设置为ripedate sql kafka将执行的是：
select * from（从树中选择apple = color = green）作为子查询，其中ripedate> offsetdate