Versions in this module Expand all Collapse all v0 v0.1.0 Feb 6, 2025 Changes in this version + const DefaultBatchSize + const DefaultMaxAttempts + func MapCodecString(codec string) (kafka.Compression, error) + type Exporter struct + func New(source *processor.KafkaMessageBuffer, topic string, brokers []string, ...) *Exporter + func (e *Exporter) Export(ctx context.Context) error + type MechanismFactory func(username, password string) (sasl.Mechanism, error) + func MapMechanismString(mechanism string) (MechanismFactory, error) + type Option func(*Exporter) + func UseSASL(mechanism sasl.Mechanism) Option + func UseTLS(config *tls.Config) Option + func WithCompression(codec kafka.Compression) Option + func WithLogger(logger *zap.Logger) Option + type TLSData struct + CA []byte + Cert []byte + Key []byte + SkipVerify bool + func (t *TLSData) Build() (*tls.Config, error)
Go to main page