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

>>阅读原文<<