From 98976f5904947bda76763ef8635324f43181294b Mon Sep 17 00:00:00 2001 From: Vlad Gorodetsky Date: Wed, 15 Apr 2020 11:24:34 +0300 Subject: [PATCH] Add support for kafka 2.5.0 --- .github/workflows/ci.yml | 2 +- utils.go | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml index 46f015eca..f79a3274c 100644 --- a/.github/workflows/ci.yml +++ b/.github/workflows/ci.yml @@ -10,7 +10,7 @@ jobs: fail-fast: false matrix: go-version: [1.12.x, 1.13.x, 1.14.x] - kafka-version: [2.3.1, 2.4.0] + kafka-version: [2.3.1, 2.4.1, 2.5.0] platform: [ubuntu-latest] env: diff --git a/utils.go b/utils.go index 75d0f606a..d138a5eb3 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