librdkafka: 如何設置Kafka消費者訂閱消息的起始偏移位置

缺省配置 默認情況下,Kafka消費者從最後一次提交的偏移量位置(offset)開始消費消息,如果Topic+Partition和Group之前沒有提交過偏移量,它訂閱消息開始位置取決於Topic的配置屬性auto.offset.reset的設置。默認爲最新(latest),也就是在分區末尾開始消耗(僅消費新消息)。相關配置可以參考官方文檔:https://kafka.apache.org/doc
相關文章
相關標籤/搜索