[
https://issues.apache.org/jira/browse/FLINK-37380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arvid Heise updated FLINK-37380:
--------------------------------
Release Note: The transactional id prefix is now mandatory for all exactly
once KafkaSinks.
> 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)
