使用事务生产者时,报如下错误,大家有没碰到的
org.apache.kafka.common.KafkaException: Cannot execute transactional method because we are in an error state
at org.apache.kafka.clients.producer.internals.TransactionManager.maybeFailWithError(TransactionManager.java:782) ~[kafka-clients-1.0.0.jar:na]
at org.apache.kafka.clients.producer.internals.TransactionManager.beginAbort(TransactionManager.java:228) ~[kafka-clients-1.0.0.jar:na]
at org.apache.kafka.clients.producer.KafkaProducer.abortTransaction(KafkaProducer.java:637) ~[kafka-clients-1.0.0.jar:na]