commit d85e52bd90977335cb240ff9cefe1c8587c8a918
author kesavand <kesavan.duraiswamy@gmail.com> Tue Mar 15 16:38:08 2022 +0530
committer kesavand <kesavan.duraiswamy@gmail.com> Tue Mar 29 12:27:13 2022 +0530
tree 0903aa67f010a8573065c58c4e393c645dafb34b
parent 42f4ca0a12b9cfee11be74422d6642acb2a29a4a

[VOL-4663] create voltha event topic (voltha.events) with conifgurable no of partitions and replication factor

Change-Id: I2eb23a374b548d13b3e47d5f65d6d37d14419e32

pkg/kafka/client.go

diff --git a/pkg/kafka/client.go b/pkg/kafka/client.go
index fdc05bc..afc2955 100755
--- a/pkg/kafka/client.go
+++ b/pkg/kafka/client.go
@@ -77,4 +77,5 @@
 	SendLiveness(ctx context.Context) error
 	EnableLivenessChannel(ctx context.Context, enable bool) chan bool
 	EnableHealthinessChannel(ctx context.Context, enable bool) chan bool
+	ListTopics(ctx context.Context) ([]string, error)
 }