我的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之前,它再次抛出一个异常“从准备就绪状态到初始化状态的无效转换尝试”。
我做错什么了?
暂无答案!
目前还没有任何答案,快来回答吧!