使用Python操作kafka，获取分区偏移量时无响应：

tp = TopicPartition(topic, p)
print(tp)
consumer.assign([tp])
fp=consumer.seek_to_beginning(tp)
print('start')
earliest = consumer.position(tp)

执行到最后一行时，程序无响应。但是无报错，似乎存于监听状态。

希望经验丰富的老哥们多多指教！
感谢！