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

>>阅读原文<<