Versions in this module Expand all Collapse all v0 v0.74.0 Mar 10, 2023 Changes in this version + func ConfigureAuthentication(config Authentication, saramaConfig *sarama.Config) error + func NewFactory(options ...FactoryOption) exporter.Factory + 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 WithLogsMarshalers(logsMarshalers ...LogsMarshaler) FactoryOption + func WithMetricsMarshalers(metricMarshalers ...MetricsMarshaler) FactoryOption + 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 + Version int + 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)