VOL-3978 - change the version of build tools
- fixed two minor errors in code that go 1.16 vet caught
Change-Id: Ibc5d7e966cb89bdb557a640fac70e2101a7b27b6
diff --git a/pkg/kafka/client.go b/pkg/kafka/client.go
index 0337432..eee9631 100755
--- a/pkg/kafka/client.go
+++ b/pkg/kafka/client.go
@@ -17,8 +17,9 @@
import (
"context"
- ca "github.com/opencord/voltha-protos/v4/go/inter_container"
"time"
+
+ ca "github.com/opencord/voltha-protos/v4/go/inter_container"
)
const (
@@ -37,9 +38,7 @@
)
const (
- DefaultKafkaHost = "127.0.0.1"
- DefaultKafkaPort = 9092
- DefaultKafkaAddress = DefaultKafkaHost + ":" + string(DefaultKafkaPort)
+ DefaultKafkaAddress = "127.0.0.1:9092"
DefaultGroupName = "voltha"
DefaultSleepOnError = 1
DefaultProducerFlushFrequency = 10