search

doujiang24 / lua-resty-kafka

Lua kafka client driver for the Openresty based on the cosocket API
BSD 3-Clause "New" or "Revised" License
801 stars 274 forks source link

在正常运行了一段时间后，在执行producer:send会出现 #107

Open 282857484 opened 3 years ago

282857484 commented 3 years ago

在正常运行了一段时间后，在执行producer:send会出现 "not found brokerinfo" 然后重启程序就好了

我的配置是这样的： connection_config = { productr_type = "async", max_buffering = 8000, request_timeout = 5000, --ms refresh_interval = 50000, max_retry = 3, api_version = 0, batch_num = 200, error_handle = nil, keepalive_timeout = 100000, keepalive_size = 1500 }

bingoabs commented 2 years ago

I came across the similiar case. Maybe your kafka broker already crash, and restart, so the old connection information is not vlaid. Can you help to check it.