1.模拟生产者
模块：KafkaProducer
两个重要的方法:
a.设置kafka地址：
producer=KafkaProducer(bootstrap_servers='xxx.xxx.xxx.xxx:8086')
注意：可以逗号分隔，放多个地址
b.设置主题和发送消息
producer.send('topic',msg, partition=0)
注意：msg默认是字节码，可以接收json格式

所需kafka相关参数：kafka地址、端口、主题、分区
简易demo:

from kafka import KafkaProducer

if __name__ == '__main__':
    producer = KafkaProducer(bootstrap_servers='xxx.xxx.xxx.xxx:8086')#kafka地址和端口
    msg="""{"behavior":"start_processing","etype":4,"group":4359012600179200,"rnum":"6001190787657137","role":1,"time":"2020-01-20 00:00:00","time_usec":711014,"uip":"183.228.87.150","uname":"童烨","unum":"7744488","version":""}
    """
    print(msg)

    msg1=bytes(msg, encoding ='utf-8')
    producer.send('test-topic', msg1, partition=0)
    producer.close()