common

Jan 19, 2024

Changes in this version

type ConfigTLS

+ TLSEnabled bool

Nov 9, 2023

Changes in this version

+ var ErrSASLInvalidAuth = errors.New("invalid sasl auth, please specify both saslUsername and saslPassword")

+ type Config struct

+ ClientID string

+ Servers []string

+ Topic string

+ func (c Config) FranzClientOpts(logger *zerolog.Logger) []kgo.Opt

+ func (c Config) TryDial(ctx context.Context) error

+ func (c Config) Validate() error

+ func (c Config) WithFranzClientOpts(opts ...kgo.Opt) Config

+ type ConfigSASL struct

+ Mechanism string

+ Password string

+ Username string

+ func (c ConfigSASL) SASL() sasl.Mechanism

+ func (c ConfigSASL) Validate() error

+ type ConfigTLS struct

+ CACert string

+ ClientCert string

+ ClientKey string

+ InsecureSkipVerify bool

+ func (c ConfigTLS) TLS() *tls.Config

+ func (c ConfigTLS) Validate() error