tp = TopicPartition(topic, p)
print(tp)
consumer.assign([tp])
fp=consumer.seek_to_beginning(tp)
print('start')
earliest = consumer.position(tp)
执行到最后一行时,程序无响应。但是无报错,似乎存于监听状态。
希望经验丰富的老哥们多多指教!
感谢!
tp = TopicPartition(topic, p)
print(tp)
consumer.assign([tp])
fp=consumer.seek_to_beginning(tp)
print('start')
earliest = consumer.position(tp)
执行到最后一行时,程序无响应。但是无报错,似乎存于监听状态。
希望经验丰富的老哥们多多指教!
感谢!