diff --git a/pkg/kafka/client.go b/pkg/kafka/client.go
index d977e38..0337432 100755
--- a/pkg/kafka/client.go
+++ b/pkg/kafka/client.go
@@ -17,7 +17,7 @@
 
 import (
 	"context"
-	ca "github.com/opencord/voltha-protos/v3/go/inter_container"
+	ca "github.com/opencord/voltha-protos/v4/go/inter_container"
 	"time"
 )