必然要返回一个0到partition_cnt-1之间的值，可能是在partitioning不能执行的时辰返回特定RD_KAFKA_PARTITION_UA值。
-rd_kafka_message_t工具成员：
err：错误返回值。非0值暗示呈现错误，err是rd_kafka_resp_err_t范例数据。假如是0则暗示举办了恰当的动静抓取，而且payload中包括了message。
rkt，partition：topic和partition信息
payload，len：动静的payload数据可能错误的动静（err！=0）
key，key_len：可选参数，首要是用来获取特定的动静。
offset：动静的偏移地点

一些函数

* rd_kafka_consume_start()函数的参数：

rkt： 举办consume的topic， 由前面rd_kafka_topic_new()建设

partition：举办consume的partition

offset：开始consume的动静偏移。这个偏移也许是一个绝对动静偏移，可能是RD_KAKFA_OFFSET_STORED来行使存储的offset，也也许是两个特定偏移之一：RD_KAFKA_OFFSET_BEGINNING，从partition动静行列的开始举办consume；RD_KAFKA_OFFSET_END：从partition中的将要produce的下一条信息开始（忽略即当前全部的动静）。


在topic+partition的consumer启动之后，librdkafka将实利用当地动静行列中的动静数量保持在queued.min.messages，一方重复的从broker获打动静。


当地动静行列将通过以下三种差异的consum  APIs举办consume：

rd_kafka_consume()Ｔ媚课consume一条动静

rd_kafka_consume_batch()：批处理赏罚consume，一条或多条

rd_kafka_consume_callback()：consume当地动静行列中的全部动静，并挪用回调函数处理赏罚每条动静


上述三种方法凭证机能分列的，rd_kafka_consume()是最慢的，rd_kafka_consume_callback()最快。差异的需求可以选择差异的实现方法。


一条consumed动静，由每一个consume函数提供或返回，详细是由rd_kafka_messag_t范例工具生涯。</big>

sparkstreaming 部门

（编辑：湖南网）

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