[
https://issues.apache.org/jira/browse/FLINK-37380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-37380.
--------------------------------
Fix Version/s: kafka-4.0.0
Assignee: Hongshun Wang
Resolution: Implemented
Implemented via main: 7c112abe8bf78e0cd8a310aaa65b57f6a70ad30a
> Change TransactionalIdPrefix to a required option if Exactly once in Kafka
> Connector
> -------------------------------------------------------------------------------------
>
> Key: FLINK-37380
> URL: https://issues.apache.org/jira/browse/FLINK-37380
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Kafka
> Affects Versions: kafka-3.4.0
> Reporter: Hongshun Wang
> Assignee: Hongshun Wang
> Priority: Critical
> Labels: pull-request-available
> Fix For: kafka-4.0.0
>
>
> As discuss in https://issues.apache.org/jira/browse/FLINK-37356, currently,
> default kafka transaction id prefix is easy to same, which maybe case Txn
> invalid state.
>
> I do recomand change TransactionalIdPrefix to a required option if Exactly
> once in Kafka Connector
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
