偏移量管理 - Confluent JDBC 连接器处于查询模式
Offset Management - Confluent JDBC Connector in query mode
根据confluent文档，当我们使用查询模式时，我们必须进行偏移量管理。根据我的理解，我们需要跟踪最后更新的时间戳，并在每次重新启动程序时将其传递到 where 子句中。谁能确认一下理解是否正确？提前感谢您的帮助！
两者都可以 - 除了查询之外，您仍然可以设置时间戳和递增模式。它只会根据 timestamp.column.name and/or incrementing.column.name 字段添加一个 where 语句。如果您的查询需要 where 语句
，您甚至可以使用子查询
例如，您可以将查询设置为：select * from (select apples from tree where color = green) as subquery
timestamp.column.name 设置为成熟 sql kafka 将执行的是：
select * from (select apples from tree where color = green) 作为子查询 where ripedate > offsetdate
根据confluent文档，当我们使用查询模式时，我们必须进行偏移量管理。根据我的理解，我们需要跟踪最后更新的时间戳，并在每次重新启动程序时将其传递到 where 子句中。谁能确认一下理解是否正确？提前感谢您的帮助！
两者都可以 - 除了查询之外，您仍然可以设置时间戳和递增模式。它只会根据 timestamp.column.name and/or incrementing.column.name 字段添加一个 where 语句。如果您的查询需要 where 语句
，您甚至可以使用子查询例如，您可以将查询设置为：select * from (select apples from tree where color = green) as subquery
timestamp.column.name 设置为成熟 sql kafka 将执行的是：
select * from (select apples from tree where color = green) 作为子查询 where ripedate > offsetdate