Arvid Heise created FLINK-38451:
-----------------------------------
Summary: KafkaCommitter logs ERRORs unnecessarily during
cancellation
Key: FLINK-38451
URL: https://issues.apache.org/jira/browse/FLINK-38451
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: kafka-5.0.0
Reporter: Arvid Heise
Assignee: Arvid Heise
When cancelling a job, we may interrupt the KafkaCommitter. This currently
leads to ERROR log
{noformat}
Sep 24, 2025 @ 19:38:13.182 ERROR Transaction
(CommitRequestImpl{state=RECEIVED, numRetries=0, committable=..., subtaskId=3,
transactionIdInPool=6, idPoolRangeStartId=5, idPoolRangeEndIdExclusive=10,
recoveryCounter=1,
producer=org.apache.flink.connector.kafka.sink.Recyclable@4fc7cb65}})
encountered error and data has been potentially lost.{noformat}
However, that exception is expected and not leading to any data loss beyond any
inconsistencies expected because of cancellation.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
