I think the code is used to work around the 'cosocket API disabled' limitation in log phase. I agree with you that we should take care about the max of the timers. Perhaps, we can buffer the data and use constant number of timer to flush it?
~Jarvis.Qiu <[email protected]> 于2020年3月31日周二 下午6:00写道： > the code in: > https://github.com/apache/incubator-apisix/blob/master/lua/apisix/plugins/kafka-logger.lua#L101 > > The limit of lua_max_pending_timers and lua_max_running_timers that may be > reached.
