Versions in this module Expand all Collapse all v0 v0.20.0 Nov 6, 2022 Changes in this version + func ConfigureAuthentication(config Authentication, saramaConfig *sarama.Config) error + func NewFactory(options ...FactoryOption) component.ExporterFactory + type AWSMSKConfig struct + BrokerAddr string + Region string + type Authentication struct + Kerberos *KerberosConfig + PlainText *PlainTextConfig + SASL *SASLConfig + TLS *configtls.TLSClientSetting + type Config struct + Authentication Authentication + Brokers []string + Encoding string + Metadata Metadata + Producer Producer + ProtocolVersion string + Topic string + func (cfg *Config) Validate() error + type FactoryOption func(factory *kafkaExporterFactory) + func WithTracesMarshalers(tracesMarshalers ...TracesMarshaler) FactoryOption + type KerberosConfig struct + ConfigPath string + KeyTabPath string + Password string + Realm string + ServiceName string + UseKeyTab bool + Username string + type LogsMarshaler interface + Encoding func() string + Marshal func(logs plog.Logs, topic string) ([]*sarama.ProducerMessage, error) + type Metadata struct + Full bool + Retry MetadataRetry + type MetadataRetry struct + Backoff time.Duration + Max int + type MetricsMarshaler interface + Encoding func() string + Marshal func(metrics pmetric.Metrics, topic string) ([]*sarama.ProducerMessage, error) + type PlainTextConfig struct + Password string + Username string + type Producer struct + Compression string + FlushMaxMessages int + MaxMessageBytes int + RequiredAcks sarama.RequiredAcks + type SASLConfig struct + AWSMSK AWSMSKConfig + Mechanism string + Password string + Username string + type TracesMarshaler interface + Encoding func() string + Marshal func(traces ptrace.Traces, topic string) ([]*sarama.ProducerMessage, error) + type XDGSCRAMClient struct + func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error) + func (x *XDGSCRAMClient) Done() bool + func (x *XDGSCRAMClient) Step(challenge string) (response string, err error)