[VOL-4663] create voltha event topic (voltha.events) with conifgurable no of partitions and replication factor
Change-Id: I2eb23a374b548d13b3e47d5f65d6d37d14419e32
diff --git a/pkg/mocks/kafka/kafka_client.go b/pkg/mocks/kafka/kafka_client.go
index ea410ac..a9b434f 100644
--- a/pkg/mocks/kafka/kafka_client.go
+++ b/pkg/mocks/kafka/kafka_client.go
@@ -174,3 +174,8 @@
logger.Debug(ctx, "EnableHealthinessChannel - unimplemented")
return nil
}
+
+func (kc *KafkaClient) ListTopics(ctx context.Context) ([]string, error) {
+ topics := []string{"voltha.events", "myTopic"}
+ return topics, nil
+}