Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ClientCertificateSecretRef ¶ added in v0.2.0
type ClientCertificateSecretRef struct { Name string `json:"name"` Namespace string `json:"namespace"` KeyField string `json:"keyField,omitempty"` CertField string `json:"certField,omitempty"` }
ClientCertificateSecretRef is a TLS option for enable mTLS
type Config ¶
type Config struct { Brokers []string `json:"brokers"` SASL *SASL `json:"sasl,omitempty"` TLS *TLS `json:"tls,omitempty"` }
Config is a Kafka client configuration
type SASL ¶
type SASL struct { Mechanism string `json:"mechanism"` Username string `json:"username"` Password string `json:"password"` }
SASL is an sasl option
type TLS ¶ added in v0.2.0
type TLS struct { ClientCertificateSecretRef *ClientCertificateSecretRef `json:"clientCertificateSecretRef,omitempty"` InsecureSkipVerify bool `json:"insecureSkipVerify"` }
TLS is an option for enabling encryption in transit
Click to show internal directories.
Click to hide internal directories.