返回到文章

采纳

编辑于 2年前

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

kafka python

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

producer = KafkaProducer(bootstrap_servers = [])
topic = 'prometheus'
producer.send(topic,j) 
producer.close()