diff --git a/utils.go b/utils.go index 75d0f606a4..d138a5eb32 100644 --- a/utils.go +++ b/utils.go @@ -160,6 +160,7 @@ var ( V2_2_0_0 = newKafkaVersion(2, 2, 0, 0) V2_3_0_0 = newKafkaVersion(2, 3, 0, 0) V2_4_0_0 = newKafkaVersion(2, 4, 0, 0) + V2_5_0_0 = newKafkaVersion(2, 5, 0, 0) SupportedVersions = []KafkaVersion{ V0_8_2_0, @@ -185,9 +186,10 @@ var ( V2_2_0_0, V2_3_0_0, V2_4_0_0, + V2_5_0_0, } MinVersion = V0_8_2_0 - MaxVersion = V2_4_0_0 + MaxVersion = V2_5_0_0 ) //ParseKafkaVersion parses and returns kafka version or error from a string