| commit | 92fac10d4ea8649d140d6604d5389a4f3ae8f851 | [log] [tgz] |
|---|---|---|
| author | kesavand <kesavan.duraiswamy@gmail.com> | Wed Mar 16 12:33:06 2022 +0530 |
| committer | kesavand <kesavan.duraiswamy@gmail.com> | Thu Mar 31 18:22:11 2022 +0530 |
| tree | 5a9d0ad4327f54120c803ec64a0e8e5017017b24 | |
| parent | b955562f29334bef5751ec104298de770df9c7a4 [diff] [blame] |
[VOL-4663] create voltha event topic (voltha.events) with conifgurable no of partitions and replication factor Change-Id: I55b40d97afaed0d75240fd6557f26da90950f6c5
diff --git a/vendor/github.com/opencord/voltha-lib-go/v7/pkg/mocks/kafka/kafka_client.go b/vendor/github.com/opencord/voltha-lib-go/v7/pkg/mocks/kafka/kafka_client.go index ea410ac..a9b434f 100644 --- a/vendor/github.com/opencord/voltha-lib-go/v7/pkg/mocks/kafka/kafka_client.go +++ b/vendor/github.com/opencord/voltha-lib-go/v7/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 +}