运行一段时间 就出现这个kafka事务问题

报错中提及的epoch是记录事务所处的状态用的(理解为事务的元数据信息记录)：We introduce the notion of a producer epoch, which enables us to ensure that there is only one legitimate active instance of a producer with a given TransactionalId, and hence enables us to maintain transaction guarantees in the event of failures.

Kafka事务的详细流程官方的wiki上有说明，详见参考中的第二个链接，这里就不搬运了...kafka事务每个阶段都会有对应的状态。后续有空再研究研究吧...个人其实不太想投入太多时间在kafka上，毕竟它还是挺稳定的。