lua-resty-kafka
lua-resty-kafka copied to clipboard
Lua entry thread aborted cause by unknown errcode
What version
lua-resty-kafka v0.08
What happened
After I upgrade Kafka Cluster from 0.10.2.1 to 3.1 . Got following error logs on one broker disk full:
Following the error log, I think the problem cause by errcode not covered in Errors table.
https://github.com/doujiang24/lua-resty-kafka/blob/v0.08/lib/resty/kafka/producer.lua#L183
What I expect
I saw the latest release 0.20 already extend error list, but still not considered the error code list in kafka protocol could extend in the future.
Maybe we shouldn't pass any err==nil into sendBuffer:err
. In my opinion, we can fallback any errcode not covered into UNKNOWN_SERVER_ERROR
and show that errcode in log.