diff --git a/pulsar/internal/connection.go b/pulsar/internal/connection.go index 1f80d20d33..e2ae7ac845 100644 --- a/pulsar/internal/connection.go +++ b/pulsar/internal/connection.go @@ -823,6 +823,11 @@ func (c *connection) handleAuthChallenge(authChallenge *pb.CommandAuthChallenge) return } + // Brokers expect authData to be not nil + if authData == nil { + authData = []byte{} + } + cmdAuthResponse := &pb.CommandAuthResponse{ ProtocolVersion: proto.Int32(PulsarProtocolVersion), ClientVersion: proto.String(ClientVersionString),