原始问题:
python 消费kafka如何指定从某个时间点开始消费
Python 消费 Kafka 可以通过使用 Kafka 的 Consumer API 来实现,指定从某个时间点开始消费的步骤如下:
- 调用 KafkaConsumer.offsetsForTimes() 方法获取分区的 offset 。
- 调用 KafkaConsumer.seek() 方法将 consumer 的 offset 设置到请求的时间戳对应的 offset 处。
- 通过调用 consumer.poll() 方法来开始从请求时间戳对应的 offset 开始消费数据。
Prev:AI繪圖時,怎麼讓其出現幼女