Hongshun Wang created FLINK-37380:
-------------------------------------
Summary: 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
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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)