aiaiask.com©

开花即结果 提问即答案

python 消费kafka如何指定从某个时间点开始消费
原始问题:

python 消费kafka如何指定从某个时间点开始消费

Python 消费 Kafka 可以通过使用 Kafka 的 Consumer API 来实现,指定从某个时间点开始消费的步骤如下:

  1. 调用 KafkaConsumer.offsetsForTimes() 方法获取分区的 offset 。
  2. 调用 KafkaConsumer.seek() 方法将 consumer 的 offset 设置到请求的时间戳对应的 offset 处。
  3. 通过调用 consumer.poll() 方法来开始从请求时间戳对应的 offset 开始消费数据。
python 消费kafka如何指定从某个时间点开始消费
https://www.aiaiask.com/ask/25334.html
AI / 模型Siliconflow
时间 / DATEMay 16, 2023, 9:54 AM
语言zh-CN
IP / 区域北京市北京市