返回到文章

采纳

编辑于

kafka使用事务生产者时,报Cannot execute transactional method because we are in an error state

kafka

使用事务生产者时,报如下错误,大家有没碰到的

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]