通过pykafka接收Kafka消息队列的方法
没有Kafka环境，所以也没有进行验证。感觉今后应该能用到，所以借抄在此，备查。pykafka使
pykafka
没有Kafka环境，所以也没有进行验证。感觉今后应该能用到，所以借抄在此，备查。pykafka使
1.1安装模块pipinstallpykafka1.2基本使用#-*coding:utf8*-frompykafkaimportKafkaClienthost='IP:9092,IP:9092,IP:9092
生产者代码：#-*coding:utf8*-frompykafkaimportKafkaClienthost='IP:9092,IP:9092,IP:9092'client=KafkaClient(hosts=hos