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

Lua entry thread aborted cause by unknown errcode #131

Open sko00o opened 2 years ago

sko00o commented 2 years ago

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:

image

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 image

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.