Versions in this module Expand all Collapse all v1 v1.3.0 May 27, 2024 v1.2.84 Jan 17, 2024 v1.2.50 Jan 12, 2024 v1.2.11 Dec 19, 2023 Changes in this version + func RegisterSASL(mechanism Mechanism) + type Ack string + func (ack Ack) Config() kgo.Acks + type Compression struct + Level int + Name string + func (compression *Compression) Config() (v kgo.CompressionCodec) + type Config struct + Consumers map[string]ConsumerConfig + Producers ProducerConfig + type ConsumerConfig struct + Balancers []GroupBalancer + Group string + HeartbeatInterval time.Duration + Isolation IsolationLevel + KeepControl bool + KeepRetryableFetchErrors bool + MaxBytes string + MaxConcurrentFetches int + MaxPartitionBytes string + MaxPollRecords int + MaxWait time.Duration + MinBytes string + PartitionBuffer int + Rack string + RebalanceTimeout time.Duration + RequireStable bool + SessionTimeout time.Duration + Topics []string + func (config *ConsumerConfig) Options() (opts []kgo.Opt, err error) + type Generic struct + AllowAutoTopicCreation bool + Brokers []string + ConnIdleTimeout time.Duration + DialTimeout time.Duration + MaxBrokerReadBytes string + MaxBrokerWriteBytes string + Meta MetaConfig + RequestTimeoutOverhead time.Duration + Retries int + RetryTimeout time.Duration + SASL SASLConfig + SSL SSLConfig + func (config *Generic) NewClient(id string, version versions.Version, log logs.Logger) (v *kgo.Client, err error) + func (config *Generic) Options(id string, version versions.Version, log logs.Logger) (v []kgo.Opt, err error) + type GroupBalancer string + func (config GroupBalancer) Config() kgo.GroupBalancer + type IsolationLevel string + func (config IsolationLevel) Config() kgo.IsolationLevel + type Logger struct + func (log *Logger) Level() kgo.LogLevel + func (log *Logger) Log(level kgo.LogLevel, msg string, keyvals ...any) + type Mechanism interface + Authenticate func(ctx context.Context, host string) (Session, []byte, error) + Construct func(options MechanismOptions) (err error) + Name func() string + Shutdown func() + type MechanismOptions struct + Config configures.Config + Log logs.Logger + type MetaConfig struct + MaxAge time.Duration + MinAge time.Duration + type OffsetManagerConfig struct + Name string + Options json.RawMessage + type Partitioner struct + Name string + Options json.RawMessage + func (partitioner Partitioner) Config() (v kgo.Partitioner, err error) + type PlainSASL struct + func (s *PlainSASL) Authenticate(ctx context.Context, host string) (Session, []byte, error) + func (s *PlainSASL) Construct(options MechanismOptions) (err error) + func (s *PlainSASL) Name() string + func (s *PlainSASL) Shutdown() + type PlainSASLConfig struct + Password string + Username string + Zid string + type ProducerConfig struct + Ack Ack + Compressions []Compression + DisableIdempotency bool + Enable bool + Linger time.Duration + MaxBufferedBytes string + MaxBufferedRecords int + MaxInflight int + MaxRecordBatchBytes string + MaxUnknownFailures int + Num int + Partitioner *Partitioner + RecordDeliveryTimeout time.Duration + RecordRetries int + Timeout time.Duration + func (config *ProducerConfig) Options() (opts []kgo.Opt, err error) + type SASLConfig struct + Name string + Options json.RawMessage + func (config *SASLConfig) Config(log logs.Logger) (v Mechanism, err error) + type SSLConfig struct + Enable bool + type ScramSASL struct + func (s *ScramSASL) Authenticate(ctx context.Context, host string) (Session, []byte, error) + func (s *ScramSASL) Construct(options MechanismOptions) (err error) + func (s *ScramSASL) Name() string + func (s *ScramSASL) Shutdown() + type ScramSASLConfig struct + Algo string + Password string + Username string + Zid string + type Session interface + Challenge func([]byte) (bool, []byte, error)