浏览代码

Add support for Kafka 1.1.0

Vlad Gorodetsky 8 年之前
父节点
当前提交
fffd68343c
共有 3 个文件被更改,包括 5 次插入3 次删除
  1. 1 1
      .travis.yml
  2. 1 1
      README.md
  3. 3 1
      utils.go

+ 1 - 1
.travis.yml

@@ -12,8 +12,8 @@ env:
   - KAFKA_HOSTNAME=localhost
   - KAFKA_HOSTNAME=localhost
   - DEBUG=true
   - DEBUG=true
   matrix:
   matrix:
-  - KAFKA_VERSION=0.11.0.2
   - KAFKA_VERSION=1.0.0
   - KAFKA_VERSION=1.0.0
+  - KAFKA_VERSION=1.1.0
 
 
 before_install:
 before_install:
 - export REPOSITORY_ROOT=${TRAVIS_BUILD_DIR}
 - export REPOSITORY_ROOT=${TRAVIS_BUILD_DIR}

+ 1 - 1
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
 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
 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
 grace period for older releases. This means we currently officially support
-Go 1.8 through 1.10, and Kafka 0.11 through 1.0, although older releases are
+Go 1.8 through 1.10, and Kafka 1.0 through 1.1, although older releases are
 still likely to work.
 still likely to work.
 
 
 Sarama follows semantic versioning and provides API stability via the gopkg.in service.
 Sarama follows semantic versioning and provides API stability via the gopkg.in service.

+ 3 - 1
utils.go

@@ -154,6 +154,7 @@ var (
 	V0_11_0_1 = newKafkaVersion(0, 11, 0, 1)
 	V0_11_0_1 = newKafkaVersion(0, 11, 0, 1)
 	V0_11_0_2 = newKafkaVersion(0, 11, 0, 2)
 	V0_11_0_2 = newKafkaVersion(0, 11, 0, 2)
 	V1_0_0_0  = newKafkaVersion(1, 0, 0, 0)
 	V1_0_0_0  = newKafkaVersion(1, 0, 0, 0)
+	V1_1_0_0  = newKafkaVersion(1, 1, 0, 0)
 
 
 	SupportedVersions = []KafkaVersion{
 	SupportedVersions = []KafkaVersion{
 		V0_8_2_0,
 		V0_8_2_0,
@@ -171,9 +172,10 @@ var (
 		V0_11_0_1,
 		V0_11_0_1,
 		V0_11_0_2,
 		V0_11_0_2,
 		V1_0_0_0,
 		V1_0_0_0,
+		V1_1_0_0,
 	}
 	}
 	MinVersion = V0_8_2_0
 	MinVersion = V0_8_2_0
-	MaxVersion = V1_0_0_0
+	MaxVersion = V1_1_0_0
 )
 )
 
 
 func ParseKafkaVersion(s string) (KafkaVersion, error) {
 func ParseKafkaVersion(s string) (KafkaVersion, error) {