[aiokafka ProducerClosed异步生成消息时发生错误

Question

我正在使用aiokafka异步生成消息。我有一个使用django的Api，它正在向kafka队列生成消息。工作正常。现在，当我将相同的api转换为使用aiohttp服务器时，将出现以下错误：-

aiokafka.errors.ProducerClosed：ProducerClosed

成功生成第一条消息。上述错误将在第二条消息产生中出现。

loop = asyncio.get_event_loop()
producer = AIOKafkaProducer(
    loop=loop,
    bootstrap_servers="127.0.0.1:9092"
)
await producer.start()
response = await producer.send_and_wait(queue_name, msg)
await producer.stop()

[aiokafka文档中没有有关此错误的信息。请帮助。

Answer 1

aiokafka.errors.ProducerClosed：ProducerClosed

将消息发送给封闭的生产者时，此错误occurs。>>

如果要在处理程序之间共享生产者，请确保在产生第一条消息后不要关闭它。