[
https://issues.apache.org/jira/browse/FLINK-31363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927059#comment-17927059
]
Hongshun Wang commented on FLINK-31363:
---------------------------------------
Hi, [~tzulitai] [~lightzhao]
I have noticed you said "data cannot be consumed in READ_COMMITTED mode". I
don't understand why.
Though the transaction is in an invalid state, no any data is written into
Kafka topic partition( because in this case, the transaction is empty). It will
not influence any Kafka topic partition's LSO, why data cannot be consumed in
READ_COMMITTED mode?
I have met data cannot be consumed in READ_COMMITTED mode, thus I wonder
whether this issue is the problem. I do hope you can help me answer it, thanks
a lot.
> KafkaSink failed to commit transactions under EXACTLY_ONCE semantics
> --------------------------------------------------------------------
>
> Key: FLINK-31363
> URL: https://issues.apache.org/jira/browse/FLINK-31363
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Affects Versions: 1.17.0, 1.16.1, 1.18.0
> Reporter: lightzhao
> Assignee: Tzu-Li (Gordon) Tai
> Priority: Blocker
> Labels: pull-request-available
> Fix For: kafka-3.0.0
>
> Attachments: image-2023-03-08-10-54-51-410.png
>
>
> When KafkaSink starts Exactly once and no data is written to the topic during
> a checkpoint, the transaction commit exception is triggered, with the
> following exception.
> [Transiting to fatal error state due to
> org.apache.kafka.common.errors.InvalidTxnStateException: The producer
> attempted a transactional operation in an invalid state.]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
