From 59456c40b7bef76567540a65fb692a8c716b87c6 Mon Sep 17 00:00:00 2001 From: Jorge Pereira Date: Thu, 20 Jul 2023 20:44:04 +0100 Subject: [PATCH 1/3] fix: client reconnected every authenticationRefreshCheckSeconds --- pulsar/auth/tls.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar/auth/tls.go b/pulsar/auth/tls.go index 4b5b9cd90d..58df22ff0b 100644 --- a/pulsar/auth/tls.go +++ b/pulsar/auth/tls.go @@ -70,7 +70,7 @@ func (p *tlsAuthProvider) GetTLSCertificate() (*tls.Certificate, error) { } func (p *tlsAuthProvider) GetData() ([]byte, error) { - return nil, nil + return []byte{}, nil } func (tlsAuthProvider) Close() error { From 8bc1cd5d1f9cb3e65781b6b98f70a826ee653412 Mon Sep 17 00:00:00 2001 From: Jorge Pereira Date: Wed, 26 Jul 2023 11:54:00 +0100 Subject: [PATCH 2/3] fix: client reconnected every authenticationRefreshCheckSeconds --- pulsar/auth/tls.go | 2 +- pulsar/internal/connection.go | 5 +++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/pulsar/auth/tls.go b/pulsar/auth/tls.go index 58df22ff0b..4b5b9cd90d 100644 --- a/pulsar/auth/tls.go +++ b/pulsar/auth/tls.go @@ -70,7 +70,7 @@ func (p *tlsAuthProvider) GetTLSCertificate() (*tls.Certificate, error) { } func (p *tlsAuthProvider) GetData() ([]byte, error) { - return []byte{}, nil + return nil, nil } func (tlsAuthProvider) Close() error { diff --git a/pulsar/internal/connection.go b/pulsar/internal/connection.go index 1f80d20d33..aaa0cb09b4 100644 --- a/pulsar/internal/connection.go +++ b/pulsar/internal/connection.go @@ -823,6 +823,11 @@ func (c *connection) handleAuthChallenge(authChallenge *pb.CommandAuthChallenge) return } + // Broker expect authData to be not nil + if authData == nil { + authData = []byte{} + } + cmdAuthResponse := &pb.CommandAuthResponse{ ProtocolVersion: proto.Int32(PulsarProtocolVersion), ClientVersion: proto.String(ClientVersionString), From bcef09a54e381232c023471bc5d5adec17734c31 Mon Sep 17 00:00:00 2001 From: Jorge Pereira Date: Wed, 26 Jul 2023 11:56:06 +0100 Subject: [PATCH 3/3] fix: client reconnected every authenticationRefreshCheckSeconds --- 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 aaa0cb09b4..e2ae7ac845 100644 --- a/pulsar/internal/connection.go +++ b/pulsar/internal/connection.go @@ -823,7 +823,7 @@ func (c *connection) handleAuthChallenge(authChallenge *pb.CommandAuthChallenge) return } - // Broker expect authData to be not nil + // Brokers expect authData to be not nil if authData == nil { authData = []byte{} }