Compatibility issues that arise when sending messages to different versions of Kafka.

[yuqiquan]

Using version 0.23 of lua-resty-kafka to communicate with a version 1.0 Kafka broker results in an UNSUPPORTED_VERSION error.

Through my research, I found that the version used for communication with the broker in the client.lua code is actually hardcoded.

The key point is that api_versions_encode uses a fixed v2. What confuses me is why v2 is used here when everywhere else uses v1. I can send messages to Kafka normally if I change this v2 to v1. Can you tell me the reason for using v2?

I personally think this might be a bug.

[SeungyeopShin]

+1