Fixed broken tests (#218)

beatlabs · May 28, 2020 · 2c6c55a · 2c6c55a
1 parent 7ef6482
commit 2c6c55a
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 10 deletions.
diff --git a/test/docker/kafka/consumer_group_integration_test.go b/test/docker/kafka/consumer_group_integration_test.go
@@ -14,11 +14,6 @@ import (
 	"github.com/stretchr/testify/require"
 )
 
-const (
-	groupTopic1 = "groupTopic1"
-	groupTopic2 = "groupTopic2"
-)
-
 func TestGroupConsume(t *testing.T) {
 	sent := []string{"one", "two", "three"}
 	chMessages := make(chan []string)

diff --git a/test/docker/kafka/consumer_simple_integration_test.go b/test/docker/kafka/consumer_simple_integration_test.go
@@ -13,11 +13,6 @@ import (
 	"github.com/stretchr/testify/require"
 )
 
-const (
-	simpleTopic1 = "simpleTopic1"
-	simpleTopic2 = "simpleTopic2"
-)
-
 func TestSimpleConsume(t *testing.T) {
 	sent := []string{"one", "two", "three"}
 	chMessages := make(chan []string)

diff --git a/test/docker/kafka/kafka_test.go b/test/docker/kafka/kafka_test.go
@@ -1,3 +1,5 @@
+// +build integration
+
 package kafka
 
 import (
@@ -21,6 +23,10 @@ const (
 	kafkaHost     = "localhost"
 	kafkaPort     = "9092"
 	zookeeperPort = "2181"
+	simpleTopic1  = "simpleTopic1"
+	simpleTopic2  = "simpleTopic2"
+	groupTopic1   = "groupTopic1"
+	groupTopic2   = "groupTopic2"
 )
 
 func TestMain(m *testing.M) {