config.go

package kafka

// Config is a Kafka client configuration
type Config struct {
	Brokers []string `json:"brokers"`
	SASL    *SASL    `json:"sasl,omitempty"`
	TLS     *TLS     `json:"tls,omitempty"`
}

// SASL is an sasl option
type SASL struct {
	Mechanism string `json:"mechanism"`
	Username  string `json:"username"`
	Password  string `json:"password"`
}

// TLS is an option for enabling encryption in transit
type TLS struct {
	ClientCertificateSecretRef *ClientCertificateSecretRef `json:"clientCertificateSecretRef,omitempty"`
	InsecureSkipVerify         bool                        `json:"insecureSkipVerify"`
}

// ClientCertificateSecretRef is a TLS option for enable mTLS
type ClientCertificateSecretRef struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace"`
	KeyField  string `json:"keyField,omitempty"`
	CertField string `json:"certField,omitempty"`
}