python - 何时在融合的 kafka 客户端中调用传递回调并出现错误？

Question

Confluent Kafka 库（在本例中为 python 版本）有一个 producer 方法，该方法采用传递回调函数：

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