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

只对你说 发表于: 2018-04-27   最后更新时间: 2018-04-27  
  •   0 订阅,131 游览

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

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]






发表于: 26天前   最后更新时间: 26天前   游览量:131
上一条: 到头了!
下一条: 已经是最后了!

评论…


  • 错误描述是说事务的状态不正确,贴下事务相关的代码。
    根据事务消息特性,我 启动事务消息时,会分配一个唯一的tid,但是我项目在测试服务器上运行了几天后,在一次发消息时,就一直报这个错误
  • 评论…
    • in this conversation
      提问