kafka 從指定位置消費資料

from kafka import KafkaConsumer
from kafka.structs import TopicPartition


topics = 'test'
kc = KafkaConsumer(bootstrap_servers="127.0.0.1:9092")
tp = TopicPartition(topics, 0)  # 主題，分區
kc.assign([tp])

# 開始的位置
offset = 10000
kc.seek(partition=tp, offset=offset)
for i in kc:
    print(i)