基于netcore简单操作kafka的demo，引用kafka-net-core组件

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

### Abstract这是一个示例演示项目，演示了两个微服务通过Apache Kafka消息代理以异步方式彼此通信。 这些项目包括两项服务： 用户服务 通知服务 这些服务是使用Sprint Boot和Java 11构建的。 用户服务 用户服务处理用户的批量操作： 登记 版 删除（软删除） 该服务使用内存中的H2数据库（为简单起见，因为这是一个演示项目） 通知服务 Notification-service收听Kafka主题。 当来自Kafka的消息到达时，该服务会向该消息中指定的用户发送

如下所示： 安装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