commit dd9af396e6759ac44e899f7da85ff6c5e9a96b4f
author Neha Sharma <neha.sharma70@infosys.com> Tue Apr 28 09:03:57 2020 +0000
committer Neha Sharma <neha.sharma70@infosys.com> Tue May 26 12:17:20 2020 +0000
tree bc0d1c0a9eb4bf7fa4d4b0cc630415a43bf5d925
parent e1e24735cb4cf64e8fc433d424558a9e422a5bb2

[VOL-2736]host and port should be specified as a single argument not as two separate arguments

Change-Id: I312fe753ac0fe62c942f335371e6449809ecfb85

pkg/kafka/client.go

diff --git a/pkg/kafka/client.go b/pkg/kafka/client.go
index 0919a0c..0d9e3a5 100755
--- a/pkg/kafka/client.go
+++ b/pkg/kafka/client.go
@@ -39,6 +39,7 @@
 const (
 	DefaultKafkaHost                = "127.0.0.1"
 	DefaultKafkaPort                = 9092
+	DefaultKafkaAddress             = DefaultKafkaHost + ":" + string(DefaultKafkaPort)
 	DefaultGroupName                = "voltha"
 	DefaultSleepOnError             = 1
 	DefaultProducerFlushFrequency   = 10