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)