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

>>阅读原文<<