fix: unmarshal ca, privateKey, cert as string instead of byte slice (#…

…193)

fixes #191

.gitignore

@@ -16,3 +16,4 @@ zk-multiple-kafka-multiple
 .idea
 
 config
+kminion

kafka/client_config_helper.go

@@ -115,7 +115,7 @@ func NewKgoConfig(cfg Config, logger *zap.Logger) ([]kgo.Opt, error) {
 	if cfg.TLS.Enabled {
 		// Root CA
 		if cfg.TLS.CaFilepath != "" || len(cfg.TLS.Ca) > 0 {
-			ca := cfg.TLS.Ca
+			ca := []byte(cfg.TLS.Ca)
 			if cfg.TLS.CaFilepath != "" {
 				caBytes, err := ioutil.ReadFile(cfg.TLS.CaFilepath)
 				if err != nil {
@@ -135,8 +135,8 @@ func NewKgoConfig(cfg Config, logger *zap.Logger) ([]kgo.Opt, error) {
 		hasCertFile := cfg.TLS.CertFilepath != "" || len(cfg.TLS.Cert) > 0
 		hasKeyFile := cfg.TLS.KeyFilepath != "" || len(cfg.TLS.Key) > 0
 		if hasCertFile || hasKeyFile {
-			cert := cfg.TLS.Cert
-			privateKey := cfg.TLS.Key
+			cert := []byte(cfg.TLS.Cert)
+			privateKey := []byte(cfg.TLS.Key)
 			// 1. Read certificates
 			if cfg.TLS.CertFilepath != "" {
 				certBytes, err := ioutil.ReadFile(cfg.TLS.CertFilepath)

kafka/config_tls.go

@@ -8,9 +8,9 @@ type TLSConfig struct {
 	CaFilepath            string `koanf:"caFilepath"`
 	CertFilepath          string `koanf:"certFilepath"`
 	KeyFilepath           string `koanf:"keyFilepath"`
-	Ca                    []byte `koanf:"ca"`
-	Cert                  []byte `koanf:"cert"`
-	Key                   []byte `koanf:"key"`
+	Ca                    string `koanf:"ca"`
+	Cert                  string `koanf:"cert"`
+	Key                   string `koanf:"key"`
 	Passphrase            string `koanf:"passphrase"`
 	InsecureSkipTLSVerify bool   `koanf:"insecureSkipTlsVerify"`
 }