何时在confluent kafka客户端中调用带有错误的传递回调？

Question

合流Kafka库（本例中为python版本）有一个product方法，该方法接受传递回调函数：

kafka_producer.produce(topic=topic,
                            key=key,
                            value=value,
                            on_delivery=delivery_callback)

无论消息是否成功传递，都会调用此回调：

def delivery_callback(err, msg):

我想知道调用此传递回调时出现错误的情况是什么？我试图关闭kafka代理服务器，然后生成并刷新消息。尽管如此，调用回调时并没有出现错误，而是在下一次Kafka代理运行时，前面消息的成功传递回调首先出现

那么我怎样才能有错误回调呢

Answer 1

生成主题的消息。这是一个异步操作，应用程序可以使用回调（别名on_delivery）参数传递函数（或lambda），当消息成功传递或永久传递失败时，将从poll()调用该函数

---

当前，返回回调的消息不支持消息头。即使原始消息设置了头，msg.headers()也将返回None