今天小编就为大家分享一篇python每5分钟从kafka中提取数据的例子，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧

我就废话不多说了，直接上代码吧！ import sys sys.path.append("..") from datetime import datetime from utils.kafka2file import KafkaDownloader import os """ 实现取kafka数据，文件按照取数据的间隔命名 如每5分钟从kafka取数据写入文件中，文件名为当前时间加5 """ TOPIC = "rtz_queue" HOSTS = "ip:9092,ip:9092" GROUP