From 1d96adfc42588ce57b4a96991ee706712312780c Mon Sep 17 00:00:00 2001 From: Vlad Gorodetsky Date: Tue, 2 Jul 2019 18:02:27 +0300 Subject: [PATCH] Add support for kafka 2.3.0 --- .travis.yml | 3 ++- README.md | 2 +- utils.go | 4 +++- 3 files changed, 6 insertions(+), 3 deletions(-) diff --git a/.travis.yml b/.travis.yml index da0f54c05..4331fa140 100644 --- a/.travis.yml +++ b/.travis.yml @@ -13,7 +13,8 @@ env: - DEBUG=true matrix: - KAFKA_VERSION=2.1.1 KAFKA_SCALA_VERSION=2.12 - - KAFKA_VERSION=2.2.0 KAFKA_SCALA_VERSION=2.12 + - KAFKA_VERSION=2.2.1 KAFKA_SCALA_VERSION=2.12 + - KAFKA_VERSION=2.3.0 KAFKA_SCALA_VERSION=2.12 before_install: - export REPOSITORY_ROOT=${TRAVIS_BUILD_DIR} diff --git a/README.md b/README.md index 32fdd2ef6..4cd736b67 100644 --- a/README.md +++ b/README.md @@ -21,7 +21,7 @@ You might also want to look at the [Frequently Asked Questions](https://github.c Sarama provides a "2 releases + 2 months" compatibility guarantee: we support the two latest stable releases of Kafka and Go, and we provide a two month grace period for older releases. This means we currently officially support -Go 1.10 through 1.12, and Kafka 2.0 through 2.2, although older releases are +Go 1.11 through 1.12, and Kafka 2.0 through 2.3, although older releases are still likely to work. Sarama follows semantic versioning and provides API stability via the gopkg.in service. diff --git a/utils.go b/utils.go index 5c3f9944d..7c815cd3a 100644 --- a/utils.go +++ b/utils.go @@ -160,6 +160,7 @@ var ( V2_0_1_0 = newKafkaVersion(2, 0, 1, 0) V2_1_0_0 = newKafkaVersion(2, 1, 0, 0) V2_2_0_0 = newKafkaVersion(2, 2, 0, 0) + V2_3_0_0 = newKafkaVersion(2, 3, 0, 0) SupportedVersions = []KafkaVersion{ V0_8_2_0, @@ -183,9 +184,10 @@ var ( V2_0_1_0, V2_1_0_0, V2_2_0_0, + V2_3_0_0, } MinVersion = V0_8_2_0 - MaxVersion = V2_2_0_0 + MaxVersion = V2_3_0_0 ) //ParseKafkaVersion parses and returns kafka version or error from a string