Sergey Nuyanzin created FLINK-31756:
---
Summary: KafkaTableITCase.testStartFromGroupOffsetsNone fails due
to UnknownTopicOrPartitionException
Key: FLINK-31756
URL: https://issues.apache.org/jira/browse/FLINK-31756
Hi Alexander,
Yes, Kafka’s exactly-once semantics are used to avoid duplicated records in
case of producer retries
or failovers. But as I explained above, it can’t avoid intentionally
duplicated records. Actually, I would
like to call them "upsert records" instead of "duplicates", that's why the
c
