METADATA(forNEXTtake)是什么意思中文翻译

vt.& vi. (使)被钩住(使)被卡住;

n. 抓;隱情;捕获量;挂钩;

vi. 锁住;着火;[棒球]当接球手;

adj. 迷惑人的;令人容易上当的;引人注目的;令人感兴趣的;

}

这是高水平消费者支持自动分區/撤销(pecl rdkafka>=mit设置为true,则消费者偏移量自动提交给Kafka的频率(以毫秒为单位)
最小:自动将偏移重置为最小偏移
最大:自动将偏移重置为最大偏移
* 其他任何事情:抛出异常消费者

指定调用将阻止等待事件的最大时间(以毫秒为单位)。对于非阻塞调用提供0作为timeout_ms。若要不确定地等待某个事件请提供-1。

当消息成功地生成时或者如果librdkafka 遇到永久故障,或者临时错误的重试计数器已经耗尽就会调用回调。

应用程序必须萣期调用rdKafka::poll()以便为排队的传递报告回调服务。

设置错误回调librdkafka 使用错误回调将ciritcal错误信号发送回应用程序。

在没有重新平衡回调的情况下這是由librdkafka自动完成的,但是注册一个重新平衡回调会使应用程序在执行其他操作时具有灵活性同时还可以执行排序/撤销操作(assinging/revocation)。例如从叧一个位置获取偏移量(在赋值时)或手动提交偏移量(在REVOKE上)

}

我要回帖

更多推荐

版权声明:文章内容来源于网络,版权归原作者所有,如有侵权请点击这里与我们联系,我们将及时删除。

点击添加站长微信