run go fmt

canned/kafka.go

@@ -4,23 +4,23 @@
 package canned
 
 import (
-"context"
-"github.com/testcontainers/testcontainers-go"
-"io/ioutil"
-"os"
+	"context"
+	"github.com/testcontainers/testcontainers-go"
+	"io/ioutil"
+	"os"
 )
 
 const (
-	clusterName = "kafka-cluster"
-	zookeeperPort    = "2181"
+	clusterName     = "kafka-cluster"
+	zookeeperPort   = "2181"
 	kafkaBrokerPort = "9092"
 	kafkaClientPort = "9093"
-	zookeeperImage = "confluentinc/cp-zookeeper:5.2.1"
-	kafkaImage = "confluentinc/cp-kafka:5.2.1"
+	zookeeperImage  = "confluentinc/cp-zookeeper:5.2.1"
+	kafkaImage      = "confluentinc/cp-kafka:5.2.1"
 )
 
 type KafkaCluster struct {
-	kafkaContainer testcontainers.Container
+	kafkaContainer     testcontainers.Container
 	zookeeperContainer testcontainers.Container
 }
 
@@ -90,7 +90,7 @@ func NewKafkaCluster() *KafkaCluster {
 
 	return &KafkaCluster{
 		zookeeperContainer: zookeeperContainer,
-		kafkaContainer: kafkaContainer,
+		kafkaContainer:     kafkaContainer,
 	}
 }
 
@@ -133,7 +133,7 @@ func createKafkaContainer(network *testcontainers.DockerNetwork) testcontainers.
 			Networks:       []string{network.Name},
 			NetworkAliases: map[string][]string{network.Name: {"kafka"}},
 			// the container only starts when it finds and run /testcontainers_start.sh
-			Cmd:            []string{"sh", "-c", "while [ ! -f /testcontainers_start.sh ]; do sleep 0.1; done; /testcontainers_start.sh"},
+			Cmd: []string{"sh", "-c", "while [ ! -f /testcontainers_start.sh ]; do sleep 0.1; done; /testcontainers_start.sh"},
 		},
 	})
 	if err != nil {

canned/kafka_test.go

@@ -44,7 +44,7 @@ func produceKafkaMessages(kafkaServer string, messages []string) {
 		kafkaProducer.Produce(&kafka.Message{
 			TopicPartition: kafka.TopicPartition{Topic: &topic, Partition: kafka.PartitionAny},
 			Value:          []byte(word),
-			Key: []byte("key"),
+			Key:            []byte("key"),
 		}, deliveryChan)
 
 		e := <-deliveryChan