commit | 0ef592cd3fa06208d23c9ad479bb28053172b7d2 | [log] [tgz] |
---|---|---|
author | kesavand <kesavan.duraiswamy@gmail.com> | Wed Mar 16 12:34:24 2022 +0530 |
committer | kesavand <kesavan.duraiswamy@gmail.com> | Tue Apr 05 18:32:04 2022 +0530 |
tree | 983f6117e911d6d438de968095a1b5bea302971c | |
parent | b23f1de81667ea49731e4a2e7a499692f2f9ef17 [diff] [blame] |
[VOL-4663] create voltha event topic (voltha.events) with conifgurable no of partitions and replication factor Change-Id: Ie7cde57f423c2e947cbc9a42f86f96fb6ac97826
diff --git a/vendor/github.com/opencord/voltha-lib-go/v7/pkg/kafka/client.go b/vendor/github.com/opencord/voltha-lib-go/v7/pkg/kafka/client.go index fdc05bc..afc2955 100644 --- a/vendor/github.com/opencord/voltha-lib-go/v7/pkg/kafka/client.go +++ b/vendor/github.com/opencord/voltha-lib-go/v7/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) }