From 41cf48c60c8f1e0d6848f3a0fb69def380ecc289 Mon Sep 17 00:00:00 2001 From: julian-nguyen Date: Fri, 1 Jul 2022 15:31:07 -0500 Subject: [PATCH] add kafka 3.2.0 version --- utils.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/utils.go b/utils.go index a9e706f10..dd40d9fdc 100644 --- a/utils.go +++ b/utils.go @@ -182,6 +182,7 @@ var ( V3_0_0_0 = newKafkaVersion(3, 0, 0, 0) V3_0_1_0 = newKafkaVersion(3, 0, 1, 0) V3_1_0_0 = newKafkaVersion(3, 1, 0, 0) + V3_2_0_0 = newKafkaVersion(3, 2, 0, 0) SupportedVersions = []KafkaVersion{ V0_8_2_0, @@ -227,9 +228,10 @@ var ( V3_0_0_0, V3_0_1_0, V3_1_0_0, + V3_2_0_0, } MinVersion = V0_8_2_0 - MaxVersion = V3_1_0_0 + MaxVersion = V3_2_0_0 DefaultVersion = V1_0_0_0 )