有关于rd_kafka_seek_partitions的代码范例不?
时间: 2023-05-11 16:03:48 浏览: 160
Python库 | knada_kafka_consumer-0.1.8-py3-none-any.whl
可以参考以下代码:
rd_kafka_topic_partition_list_t *partitions;
rd_kafka_topic_partition_list_new(&partitions, 1);
rd_kafka_topic_partition_list_add(partitions, "my_topic", 0);
rd_kafka_seek(rk, partitions, 5000);
rd_kafka_topic_partition_list_destroy(partitions);
这段代码演示了如何使用rd_kafka_seek_partitions函数来将消费者的偏移量设置为5000。其中,rd_kafka_topic_partition_list_t结构体用于存储要操作的分区信息。
阅读全文