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)