今天小编就为大家分享一篇python3连接kafka模块pykafka生产者简单封装代码，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧

1.1安装模块 pip install pykafka 1.2基本使用 # -* coding:utf8 *- from pykafka import KafkaClient host = 'IP:9092, IP:9092, IP:9092' client = KafkaClient(hosts = host) # 生产者 topicdocu = client.topics['my-topic'] producer = topicdocu.get_producer() for i in r