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

只对你说 发表于: 2018-04-27   最后更新时间: 2018-04-27 15:28:40   4,675 游览

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

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]
kafka
发表于 2018-04-27
只对你说
添加评论

根据事务消息特性，我 启动事务消息时，会分配一个唯一的tid，但是我项目在测试服务器上运行了几天后，在一次发消息时，就一直报这个错误

回复
回答于 6年前
只对你说

错误描述是说事务的状态不正确，贴下事务相关的代码。

回复
回答于 6年前
半兽人
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。