python操作kafka有没有连接池之类的框架

冰海落花 发表于: 2022-04-03   最后更新时间: 2022-04-04 00:26:01   103 游览

最近配置alertmanager的webhook,写了一个python脚本想将告警发送到kafka里,现在发现每来一条告警就要和kafka建立一次连接,写入后关闭连接,有没有框架类的kafka连接池可以用的。

producer = KafkaProducer(bootstrap_servers = [])
topic = 'prometheus'
producer.send(topic,j) 
producer.close()
发表于 2022-04-03
添加评论

KafkaProducer实例化的对象可以保存起来,后续直接用这个对象去send,永远不需要close除非你要退出程序。每次实例化再去send是很浪费性能的。

你的答案

查看kafka相关的其他问题或提一个您自己的问题
提问