大数据处理赏罚项目相干

线程和回调函数

librdkafka 内部将会有多个线程，以充实操作硬件资源。API的实现是完全线程安详的，现实应用中可以在任何时辰任何线程中挪用任何API函数而不消担忧线程安详。

一个以轮询为基本的API用来给现实应用提供信号反馈，现实应用该当凭证固按时距离断挪用rd_kafka_poll()函数。这个轮询的API将会挪用以下可的回调（都是可选的）：

动静发送陈诉回调：陈诉动静发送失败。这将应承现实应用采纳法子应对发送失败，并开释动静发送进程中占据的资源。

错误回调：陈诉错误；错误一样平常是信息化方面的，譬喻毗连broker失败，现实应用凡是不必要采纳任何法子。错误的数据范例是通过rd_kafka_resp_err_t enum范例数据，可以描写当地错误和长途broker错误。

不是poll函数引起的可选回调函数，也许是由恣意线程激发的：

logging 回调：现实应用中，用于发送librdkafka发生的log动静。

partitioner 回调：现实应用提供动静的partitioner。partitioner也许被任何线程任何时辰挪用，它也许因为统一个key而被挪用多次。Partitioner 函数有以下限定：

必然不能挪用rd_kafka_*()等函数

必然不能阻塞或延迟执行

（编辑：湖南网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!