You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

未使用事务型生产者却触发InvalidPidMappingException的Spring Boot + Spring Kafka问题求助

未使用事务型生产者却触发InvalidPidMappingException的Spring Boot + Spring Kafka问题求助

大家好!希望各位一切顺利🙂

我们团队在Kubernetes环境中运行着3个基于Spring Boot + Kotlin的Pod,消息组件采用对接Azure Event Hubs的Apache Kafka。最近一周,服务开始频繁抛出以下异常:

org.apache.kafka.common.errors.InvalidPidMappingException: The producer attempted to use a producer id which is not currently assigned to its transactional id.

遗憾的是我们团队里没人是Kafka专家,我查了不少资料后发现,这个异常似乎和Kafka事务机制相关——比如看到过专门分析这类问题的技术文章,还有Spring Kafka官方文档里也提到过相关场景。但关键问题是:我们的服务根本没有启用Kafka事务!

我已经把相关的代码示例放到了GitHub仓库中,方便大家查看具体的配置和实现细节。

现在实在摸不着头绪,为什么没开事务还会触发这个和事务PID映射相关的异常?想请教各位大佬有没有遇到过类似情况,或者能给我们一些排查的方向?

备注:内容来源于stack exchange,提问作者Francisco Angelo

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.04.16 08:28:01