From 3c723ec39110f1221dab08afdb14cfc82b2106d5 Mon Sep 17 00:00:00 2001
From: wangtao <taowang@deepglint.com>
Date: Wed, 12 Apr 2023 12:18:25 +0800
Subject: [PATCH] fix: api_version

---
 lib/resty/kafka/producer.lua | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/resty/kafka/producer.lua b/lib/resty/kafka/producer.lua
index ae468180..17560382 100644
--- a/lib/resty/kafka/producer.lua
+++ b/lib/resty/kafka/producer.lua
@@ -62,7 +62,7 @@ end
 
 local function produce_encode(self, topic_partitions)
     local version = request.API_VERSION_V1
-    if not self.api_version then
+    if not (self.api_version == API_VERSION_V0) then
         version = self.api_version 
     end
     local req = request:new(request.ProduceRequest,