conf->set("dr_cb", &ex_dr_cb, errstr);什么作用、
时间: 2023-06-15 11:03:13 浏览: 75
这段代码是librdkafka库中的一个设置回调函数的操作。其中,`conf`是librdkafka的配置对象,`&ex_dr_cb`是一个回调函数的指针,`errstr`是一个字符串指针,用于存储错误信息。
回调函数是在异步发送消息时被调用的。当消息成功发送到broker时,回调函数会被调用来通知应用程序发送成功。如果消息发送失败,回调函数也会被调用来通知应用程序发送失败的原因。
这里设置的回调函数`ex_dr_cb`是一个自定义的函数,它将在消息成功发送到broker之后被调用,将发送成功的消息的相关信息记录在日志文件中。而`errstr`则用于在发送失败时存储错误信息,以供应用程序使用。
阅读全文