davidzollo commented on PR #11390: URL: https://github.com/apache/seatunnel/pull/11390#issuecomment-5138057727
同步处理本轮 CI 失败：当前 Build 里的 `kafka-connector-it (11, ubuntu-latest)` 在 `KafkaIT.testKafkaToKafkaExactlyOnceOnStreaming` 超时，失败点是 exactly-once READ_COMMITTED 读取 helper 可能在事务控制记录/空 poll 推进 offset 时提前停止，导致等待 10 条 sink 数据一直不满足。 已推送最小修复到本 PR head： - 让 Kafka exactly-once 读取逻辑用 consumer position 跟踪扫描进度； - 对已见 offset 去重； - 只有在连续空 poll 且 position 不再推进时才停止，避免慢 CI 上提前退出读取窗口。 本地仅按 SeaTunnel PR 交付限制执行格式校验： `./mvnw -nsu -pl seatunnel-e2e/seatunnel-connector-v2-e2e/connector-kafka-e2e -DskipTests -DskipIT=true -Dmaven.gitcommitid.skip=true spotless:apply spotless:check` 结果：BUILD SUCCESS。 未运行本地 compile/test/package/E2E/Docker。等待 GitHub CI 重新跑。 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
