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