commit 606a4f0bbcf4e323a8aae7aa2dd2641465366645
author Himani Chawla <hichawla@ciena.com> Tue Mar 23 19:45:58 2021 +0530
committer Himani Chawla <hichawla@ciena.com> Fri May 14 15:22:13 2021 +0530
tree a9c0f770cd19241af5d95698d7ffda806546b18d
parent 5e4fca388b9555b9d719954096fa3e07b21e07d1

VOL-3734 optimise rpc events to be send to queue and then to kafka from the queue

Change-Id: I5e068722412b6d9526760900d9173aaf51e00946

rw_core/core/core.go

diff --git a/rw_core/core/core.go b/rw_core/core/core.go
index 4b864de..e066914 100644
--- a/rw_core/core/core.go
+++ b/rw_core/core/core.go
@@ -146,7 +146,7 @@
 		go monitorKafkaLiveness(ctx, eventProxy, cf.LiveProbeInterval, cf.NotLiveProbeInterval, clusterMessageBus)
 	}
 
-	defer kafkaClientEvent.Stop(ctx)
+	defer stopEventProxy(ctx, kafkaClientEvent, eventProxy)
 
 	// create kv path
 	dbPath := model.NewDBPath(backend)