Fix nil pointer

apache · Jul 12, 2024 · a269080 · a269080
1 parent 28547c4
commit a269080
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar/internal/rpc_client.go b/pulsar/internal/rpc_client.go
@@ -177,7 +177,7 @@ func (c *rpcClient) RequestOnCnx(cnx Connection, requestID uint64, cmdType pb.Ba
 		case res := <-ch:
 			// Ignoring producer not ready response.
 			// Continue to wait for the producer to create successfully
-			if res.error == nil && *res.RPCResult.Response.Type == pb.BaseCommand_PRODUCER_SUCCESS {
+			if res.error == nil && res.Response != nil && *res.RPCResult.Response.Type == pb.BaseCommand_PRODUCER_SUCCESS {
 				if !res.RPCResult.Response.ProducerSuccess.GetProducerReady() {
 					timeoutCh = nil
 					break