最近配置alertmanager的webhook,写了一个python脚本想将告警发送到kafka里,现在发现每来一条告警就要和kafka建立一次连接,写入后关闭连接,有没有框架类的kafka连接池可以用的。 producer = KafkaProducer(bootstrap_servers = []) topic = 'prometheus' producer.send(topic,j) producer.close()
KafkaProducer实例化的对象可以保存起来,后续直接用这个对象去send,永远不需要close除非你要退出程序。每次实例化再去send是很浪费性能的。
你的答案