Upsert Kafka 连接器消费者从哪里开始?

问题描述 投票:0回答:1

我正在尝试以更新插入模式从卡夫卡读取。一切正常。但我注意到不支持

scan.startup.mode

我的假设是否正确,即在 upsert 模式下,kafka 连接器会按设计从最早的偏移量读取整个主题,还是有其他逻辑?如果我需要减少处理的数据量,我应该减少主题保留吗?

apache-flink upsert flink-sql
1个回答
0
投票

你的版本是什么? v1.20.0 中都支持 java 风格sql 风格

最新问题
© www.soinside.com 2019 - 2025. All rights reserved.