未使用事务型生产者却触发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
相关产品推荐
相关产品推荐

