librdkafka: 配置Kafka消费者接收消息的offset position设置方法

缺省配置分析

在常规操作模式下，Kafka消费者会从上一次提交的偏移量位置开始接收消息。若当前Topic与Partition组合尚未存在任何偏移量记录，则其订阅消息的起始位置将依据Topic配置中的auto.offset.reset参数进行设定。该参数的默认值为latest，意味着消费者将从分区末尾处开始读取数据，仅处理新到达的消息。关于上述配置的具体信息，可查阅官方文档：https://kafka.apache.org/documentation/#topicconfigs。
为便于参考，此处附上相关截图：

相关接口信息

librdkafka库中包含了一个assign() API接口，用户可通过配置rd_kafka_topic_partition_t结构体中的.offset字段，来设定每个Partition的初始偏移位置。该偏移值既可以是具体的数值（大于0），也可以采用逻辑偏移方式，例如BEGINNING、END、STORED或TAIL等。在rdkafka.h头文件中，定义了用于管理Partition的结构体rd_kafka_topic_