flink producer设置精确性一次性语义，总是报错找不到事务Id 如何解决呀？

好像设置精准一次后就会报错，为之前版本好像是2.几来着。没遇到过，看着是事务ID冲突了，你试试这几个方案看看
String transactionalId = UUID.randomUUID().toString();

FlinkKafkaProducer producer = new FlinkKafkaProducer<>(
"my-topic",
new SimpleStringSchema(),
properties,
FlinkKafkaProducer.Semantic.EXACTLY_ONCE,
/ 设置 transactionalId /
transactionalId);
使用 setTransactionalIdPrefix() 方法设置 transactionalId：
Properties properties = new Properties();
properties.setProperty("bootstrap.servers", "localhost:9092");
properties.setProperty("transaction.timeout.ms", "60000");

FlinkKafkaProducer producer = new FlinkKafkaProducer<>(
"my-topic",
new SimpleStringSchema(),
properties,
FlinkKafkaProducer.Semantic.EXACTLY_ONCE);

// 设置 transactionalId 前缀
producer.setTransactionalIdPrefix("my-transactional-id-");

延长事务超时时间：使用 transaction.timeout.ms 配置属性在生产者中延长事务超时时间，以确保生产者不会过早地被视为已过期
，此回答整理自钉群“【③群】Apache Flink China社区”