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