diff --git a/pkg/source/adapter/adapter.go b/pkg/source/adapter/adapter.go index bc75c50f5..2dc34eec2 100644 --- a/pkg/source/adapter/adapter.go +++ b/pkg/source/adapter/adapter.go @@ -237,7 +237,7 @@ func (a *Adapter) newPool(address string) *redis.Pool { // configuring a connection. Dial: func() (redis.Conn, error) { var c redis.Conn - if opt.Password != "" && a.config.TLSCertificate != "" { + if a.config.TLSCertificate != "" { roots := x509.NewCertPool() ok := roots.AppendCertsFromPEM([]byte(a.config.TLSCertificate)) if !ok {