Test against Kafka v1.1.0

bsm · Jun 25, 2018 · 7e67d87 · 7e67d87
1 parent d985926
commit 7e67d87
Show file tree

Hide file tree

Showing 4 changed files with 25 additions and 29 deletions.
diff --git a/.travis.yml b/.travis.yml
@@ -3,14 +3,13 @@ language: go
 go:
   - 1.10.x
   - 1.9.x
-  - 1.8.x
 install:
   - go get -u github.com/golang/dep/cmd/dep
   - dep ensure
 env:
-  - SCALA_VERSION=2.12 KAFKA_VERSION=0.10.2.1
   - SCALA_VERSION=2.12 KAFKA_VERSION=0.11.0.1
   - SCALA_VERSION=2.12 KAFKA_VERSION=1.0.1
+  - SCALA_VERSION=2.12 KAFKA_VERSION=1.1.0
 script:
   - make default test-race
 addons:

diff --git a/Gopkg.lock b/Gopkg.lock
diff --git a/Makefile b/Makefile
@@ -1,5 +1,5 @@
 SCALA_VERSION?= 2.12
-KAFKA_VERSION?= 1.0.1
+KAFKA_VERSION?= 1.1.0
 KAFKA_DIR= kafka_$(SCALA_VERSION)-$(KAFKA_VERSION)
 KAFKA_SRC= https://archive.apache.org/dist/kafka/$(KAFKA_VERSION)/$(KAFKA_DIR).tgz
 KAFKA_ROOT= testdata/$(KAFKA_DIR)

diff --git a/cluster_test.go b/cluster_test.go
@@ -18,7 +18,7 @@ const (
 )
 
 var (
-	testKafkaRoot  = "kafka_2.12-1.0.0"
+	testKafkaRoot  = "kafka_2.12-1.1.0"
 	testKafkaAddrs = []string{"127.0.0.1:29092"}
 	testTopics     = []string{"topic-a", "topic-b"}