防止合流卡夫卡在生成时丢失消息

合流Kafka库(本例中为python版本)有一个product方法,该方法接受传递回调函数:

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

无论消息是否成功传递,都会调用此回调 还是不 :

def delivery_callback(err, msg):

相反,每100条左右,我就依靠 flush()

messages_outstanding = kafka_producer.flush()
if messages_outstanding == 0:
   //continue to the next batch of 100
else:
   //produce the batch again

将 无法生成任何消息的帐户?(报告为错误) delivery_callback

换句话说,, 我能肯定吗 刷新() 如果任何消息失败,则不会返回零 ?