kafka producer抛出一个错误:尝试从\u事务中的状态转换到\u事务中的状态无效

0s7z1bwu  于 2021-06-05  发布在  Kafka
关注(0)|答案(0)|浏览(263)

我的kafka producer抛出一个错误“尝试从\u事务中的状态转换到\u事务中的状态无效”。这就是我想要达到的目标-

KafkaProducer producer = new KafkaProducer<>(props);
producer.initTransactions();
//transaction 1
producer.beginTransaction();
//send some messages
producer.commitTransaction();

//transaction 2
producer.beginTransaction(); //here it throws an exception "Invalid transition attempted from state IN_TRANSACTION to state IN_TRANSACTION".
//send some messages
producer.commitTransaction();

producer.close();

如果我调用producer.inittransactions();在启动事务2之前,它再次抛出一个异常“从准备就绪状态到初始化状态的无效转换尝试”。
我做错什么了?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题