python使用kafka-python操作kafka實踐的示例代碼

1、先看最簡單的場景，生產者生產消息，消費者接收消息，下面是生產者的簡單代碼。 #!/usr/bin/env python # -*- coding: utf-8 -*- import json from kafka import KafkaProducer producer = KafkaProducer(bootstrap_servers='xxxx:x') msg_dict = { "sle

>>阅读原文<<