症状分析
Kafka 中止事务,因为生产者未在事务超时间隔内提交或中止,消息处于不确定状态。 该错误在生产环境中出现,但可能不会在本地开发中复现,因为触发条件依赖于部署环境或运行时配置。理解完整的症状集合有助于将此问题与类似错误区分开来。
诊断实践
按照前置事项中的诊断步骤定位原因。每个步骤包含命令和输出解读。目标是缩小问题范围:配置、运行时还是应用代码。在最小化环境中复现错误后再应用修复。
根因
The producer did not commit or abort the transaction within the configured timeout, so the coordinator aborts it and fences the producer.
修复
Increase transaction.timeout.ms, reduce the processing time between begin and commit, or split the transaction into smaller batches. 应用修复后,监控系统以确认错误在负载下或不同环境中不再复现。
验证
Run a transaction and confirm it commits within the timeout; verify aborted transactions do not produce visible messages. 如果验证通过,修复即确认;如果未通过,重新检查诊断步骤中是否遗漏了促成因素。
诊断命令
运行以下命令复现和诊断问题:
grep transaction.timeout.ms config/server.properties
kafka-producer-perf-test --transactional-id tx1