[VOL-3885] Adding retry mechanism when connecting to the kafka event cluster
Change-Id: I6411ed2e4172f9ab659a9d27c4e233c7a0f02b29
diff --git a/pkg/events/events_proxy.go b/pkg/events/events_proxy.go
index c4014ee..2301f43 100644
--- a/pkg/events/events_proxy.go
+++ b/pkg/events/events_proxy.go
@@ -187,3 +187,11 @@
return nil
}
+
+func (ep *EventProxy) EnableLivenessChannel(ctx context.Context, enable bool) chan bool {
+ return ep.kafkaClient.EnableLivenessChannel(ctx, enable)
+}
+
+func (ep *EventProxy) SendLiveness(ctx context.Context) error {
+ return ep.kafkaClient.SendLiveness(ctx)
+}