Merge pull request #1073 from bai/kafka110

Add support for Kafka 1.1.0

.travis.yml

@@ -14,6 +14,7 @@ env:
   matrix:
   - KAFKA_VERSION=0.11.0.2
   - KAFKA_VERSION=1.0.0
+  - KAFKA_VERSION=1.1.0
 
 before_install:
 - export REPOSITORY_ROOT=${TRAVIS_BUILD_DIR}

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.8 through 1.10, and Kafka 0.11 through 1.0, although older releases are
+Go 1.8 through 1.10, and Kafka 0.11 through 1.1, although older releases are
 still likely to work.
 
 Sarama follows semantic versioning and provides API stability via the gopkg.in service.

utils.go

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