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

Reply via email to