diff --git a/kafka.go b/kafka.go index c113691..eae0a7f 100644 --- a/kafka.go +++ b/kafka.go @@ -61,7 +61,7 @@ func NewTLSConfig(clientCertFile, clientKeyFile, caCertFile string) (*tls.Config tlsConfig := tls.Config{} if clientCertFile != "" && clientKeyFile == "" { - return &tlsConfig, ErrorTLSMissingKey + return &tlsConfig, errors.New(mMissing key of client certificate in kafka") } if clientCertFile == "" && clientKeyFile != "" { return &tlsConfig, errors.New("missing TLS client certificate in kafka")