[VOL-5567] Update protos
Change-Id: Ib4ec57241aab48d918fc33448020c876882d5abc
Signed-off-by: Abhay Kumar <abhay.kumar@radisys.com>
diff --git a/pkg/kafka/client.go b/pkg/kafka/client.go
index 77c529b..5b77001 100755
--- a/pkg/kafka/client.go
+++ b/pkg/kafka/client.go
@@ -25,7 +25,7 @@
"context"
"time"
- "github.com/golang/protobuf/proto"
+ "google.golang.org/protobuf/proto"
)
const (
diff --git a/pkg/kafka/sarama_client.go b/pkg/kafka/sarama_client.go
index 75025f2..c47efe9 100755
--- a/pkg/kafka/sarama_client.go
+++ b/pkg/kafka/sarama_client.go
@@ -26,9 +26,9 @@
"github.com/IBM/sarama"
"github.com/eapache/go-resiliency/breaker"
- "github.com/golang/protobuf/proto"
"github.com/google/uuid"
"github.com/opencord/voltha-lib-go/v7/pkg/log"
+ "google.golang.org/protobuf/proto"
)
// consumerChannels represents one or more consumers listening on a kafka topic. Once a message is received on that
diff --git a/pkg/kafka/utils.go b/pkg/kafka/utils.go
index fba621f..622513f 100644
--- a/pkg/kafka/utils.go
+++ b/pkg/kafka/utils.go
@@ -21,9 +21,9 @@
"strings"
"time"
- "github.com/golang/protobuf/ptypes/any"
"github.com/opencord/voltha-lib-go/v7/pkg/log"
"github.com/opencord/voltha-lib-go/v7/pkg/probe"
+ "google.golang.org/protobuf/types/known/anypb"
)
const (
@@ -59,10 +59,10 @@
type RpcResponse struct {
MType RpcMType
Err error
- Reply *any.Any
+ Reply *anypb.Any
}
-func NewResponse(messageType RpcMType, err error, body *any.Any) *RpcResponse {
+func NewResponse(messageType RpcMType, err error, body *anypb.Any) *RpcResponse {
return &RpcResponse{
MType: messageType,
Err: err,