commit 294ff52e9fbe23d3ee47528b4d1e877648a6e6db
author Abhilash S.L <abhilash.laxmeshwar@radisys.com> Wed Jun 26 18:14:33 2019 +0530
committer Abhilash Laxmeshwar <abhilash.laxmeshwar@radisys.com> Wed Jul 10 09:19:55 2019 +0000
tree aa64816ce2191a85393e63a9ed0f4c672dd10fe2
parent 404b71afed32e04ef6c344013abb70f7e0c2dbbe

VOL-1691 Fix openolt adapter getting stuck while registartion with core

Change-Id: I2e1635b4245fcc0059f5b0a601fb7a0ab9ada1c0

kafka/client.go

diff --git a/kafka/client.go b/kafka/client.go
old mode 100644
new mode 100755
index 3d37f6e..36c1ede
--- a/kafka/client.go
+++ b/kafka/client.go
@@ -16,8 +16,9 @@
 package kafka
 
 import (
-	ca "github.com/opencord/voltha-protos/go/inter_container"
 	"time"
+
+	ca "github.com/opencord/voltha-protos/go/inter_container"
 )
 
 const (
@@ -53,6 +54,7 @@
 	DefaultNumberPartitions         = 3
 	DefaultNumberReplicas           = 1
 	DefaultAutoCreateTopic          = false
+	DefaultMetadataMaxRetry         = 3
 )
 
 // MsgClient represents the set of APIs  a Kafka MsgClient must implement