今天小编就为大家分享一篇对python操作kafka写入json数据的简单demo，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧

如下所示： 安装kafka支持库pip install kafka-python from kafka import KafkaProducer import json ''' 生产者demo 向test_lyl2主题中循环写入10条json数据 注意事项：要写入json数据需加上value_serializer参数，如下代码 ''' producer = KafkaProducer( value_serializer=lambda v: json.dumps(v).e