python 在必定時間段獲取kafka數據

from pykafka import KafkaClient from pykafka.common import OffsetType import datetime def KafkaDownloader(host_, topic_, group_id_): client = KafkaClient(hosts=host_) _topic = client.topics[b

>>阅读原文<<