You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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.
The text was updated successfully, but these errors were encountered:
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 intoUNKNOWN_SERVER_ERROR
and show that errcode in log.The text was updated successfully, but these errors were encountered: