kafka记录上次偏移量
#!/usr/bin/env python# coding=utf-8from kafka import *from kafka import KafkaConsumerimport datetime,timeimport jsondef get_kafka_reviews(bootstrap_servers,topics): # print type(self.bootstrap_servers) consumer = KafkaConsumer(bootstrap_ser.
