config: add possibility to specify tls as bytes

kafka/config_tls.go

@@ -1,11 +1,16 @@
 package kafka
 
+import "errors"
+
 // TLSConfig to connect to Kafka via TLS
 type TLSConfig struct {
 	Enabled               bool   `koanf:"enabled"`
 	CaFilepath            string `koanf:"caFilepath"`
 	CertFilepath          string `koanf:"certFilepath"`
 	KeyFilepath           string `koanf:"keyFilepath"`
+	Ca                    []byte
+	Cert                  []byte
+	Key                   []byte
 	Passphrase            string `koanf:"passphrase"`
 	InsecureSkipTLSVerify bool   `koanf:"insecureSkipTlsVerify"`
 }
@@ -15,5 +20,9 @@ func (c *TLSConfig) SetDefaults() {
 }
 
 func (c *TLSConfig) Validate() error {
+	if (len(c.CaFilepath) > 0 || len(c.CertFilepath) > 0 || len(c.KeyFilepath) > 0) &&
+		(len(c.Ca) > 0 || len(c.Cert) > 0 || len(c.Key) > 0) {
+		return errors.New("if caFilepath or certFilepath or keyFilepath is specified, ca, cert, key must be empty")
+	}
 	return nil
 }