我正在尝试以更新插入模式从卡夫卡读取。一切正常。但我注意到不支持
scan.startup.mode
我的假设是否正确，即在 upsert 模式下，kafka 连接器会按设计从最早的偏移量读取整个主题，还是有其他逻辑？如果我需要减少处理的数据量，我应该减少主题保留吗？
你的版本是什么？ v1.20.0 中都支持 java 风格 或 sql 风格