0

这是关于：

confluent_kafka.cimpl.Producer

并调用：

p = confluent_kafka.cimpl.Producer(...)
# some setup stuff and then
p.commit_transaction(timeout)

实际回溯：

  File "/app/events/management/commands/outbox_producer.py", line 62, in monitor_outbox
    producer.produce(message["event_type"], key="message", value=message)
  File "/app/.heroku/python/lib/python3.8/contextlib.py", line 120, in __exit__
    next(self.gen)
  File "/app/events/event_bus/kafka/base/producer.py", line 68, in atomic_transaction
    producer.commit_transaction(timeout=commit_timeout)
  File "/app/events/event_bus/kafka/base/producer.py", line 47, in commit_transaction
    return self.producer.commit_transaction(timeout)
cimpl.KafkaException: KafkaError{FATAL,code=INVALID_PRODUCER_EPOCH,val=47,str="Failed to add partitions to transaction: Broker: Producer attempted an operation with an old epoch"}

如何重现此错误、对其进行调试或识别并掌握如何在本地进行调试？

4

0 回答 0