diff --git a/pulsar/internal/connection.go b/pulsar/internal/connection.go
index 9873ec8ced..147de3f623 100644
--- a/pulsar/internal/connection.go
+++ b/pulsar/internal/connection.go
@@ -752,7 +752,7 @@ func (c *connection) handleSendError(cmdError *pb.CommandError) {
 
 	requestID := cmdError.GetRequestId()
 
-	switch *cmdError.Error {
+	switch cmdError.GetError() {
 	case pb.ServerError_NotAllowedError:
 		request, ok := c.deletePendingRequest(requestID)
 		if !ok {