日志报错:
2018/10/15 17:54:24 [error] 292#0: [lua] producer.lua:258: buffered messages send to kafka err:not found broker, retryable: true, topic: sdklua_online_new, partition_id: 0, length: 6, context: ngx.timer, client: 10.xxx.xxx.xxx, server: 0.0.0.0:80
前阵子重启了kafka集群中的一个borker节点 ,然后就报错了,集群的配置文件是三个borker节点
local broker_list = {
{ host = "10.x.x.19", port = 9092 },
{ host = "10.x.x.20", port = 9092 },
{ host = "10.x.x.21", port = 9092 }
}
最终只能reload 解决 这个问题
可能是本人对原理不太理解吧 想学习一下 谢谢