[
https://issues.apache.org/jira/browse/FLINK-37380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hongshun Wang updated FLINK-37380:
----------------------------------
Description:
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
was:
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 https://issues.apache.org/jira/browse/FLINK-37356.
> 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
> Priority: Critical
>
> 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
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
