python和apachekafka之间的数据库不一致

cgvd09ve 于 2021-06-04 发布在 Kafka

关注(0)|答案(0)|浏览(240)

所以我将apachekafka与python和postgres数据库结合使用。我有一个叫 ImportResultDetail 使用另一个模型的外键 ImportResult .
我创建一个 ImportResult 对象，并将其pk作为消息的一部分发送给kafka生产者。在消费时，我会尝试创建一个 ImportResultDetail 对象的fk ImportResult 对象，但不知怎的，我得到一个错误，指出所说的对象不存在于数据库中（尽管它在那里）。下面是堆栈跟踪和数据库条目以更好地说明。
有人以前遇到过这种问题，并且知道这种不一致性以及如何解决它吗？