From 259a24e4216bda08b612ffbbf6490fc061ee17cc Mon Sep 17 00:00:00 2001
From: cckellogg <cckellogg@gmail.com>
Date: Tue, 27 Jul 2021 22:36:48 -0700
Subject: [PATCH] [issue 574] Fix handle send error panic

---
 pulsar/internal/connection.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 {