网站介绍:文章浏览阅读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的案例
- 链接地址:https://blog.csdn.net/weixin_43813200/article/details/124528264
- 链接标题:python使用kafka生产和消费案例_python 生产消费kafka的案例-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:9159
- 网站标签:python 生产消费kafka的案例