python使用kafka生产和消费案例_python 生产消费kafka的案例-CSDN博客

网站介绍:文章浏览阅读2.5k次。// confluent_kafka 使用案例import jsonfrom confluent-kafka import Producertopic_name = ""conf = {// 集群,或者服务器名"bootstrap.servers":"",// 安全隧道"security.protocol":"sasl_plaintext",//加密方式"sasl.mechanism":"SCRAM-SHA-256"// 账号密码"sasl.username":"","sasl._python 生产消费kafka的案例