You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@iceberg.apache.org by Андрей Романов <st...@gmail.com> on 2026/02/26 07:59:20 UTC

Issue with metadata for Iceberg tables

Hello!

I have the question about
https://github.com/databricks/iceberg-kafka-connect/issues/308

Seems like the problem, which described in this issue, saved in the main
Iceberg repository (particularly, in that line:
https://github.com/apache/iceberg/blob/main/kafka-connect/kafka-connect/src/main/java/org/apache/iceberg/connect/channel/Coordinator.java#L237
)

Can you, please, explain: why does it filter minimal offsets for envelope?
What can happen, if the condition "envelope.offset() >= minOffset" will be
deleted?

Best wishes,
Andrey Romanov