Versions in this module Expand all Collapse all v0 v0.1.0 Jan 21, 2022 Changes in this version + func FranzLogAdapter(lvl string, logger log.Logger) kgo.Logger + func Providers(optionFunc ...ProvidersOptionFunc) di.Deps + type Client struct + func NewClient(client *kgo.Client, tracer opentracing.Tracer) *Client + func (c *Client) ProduceSyncWithTracing(ctx context.Context, rs ...*kgo.Record) kgo.ProduceResults + func (c *Client) ProduceWithTracing(ctx context.Context, r *kgo.Record, promise func(*kgo.Record, error)) + type Config struct + Acks int16 + AllowAutoTopicCreation bool + AutocommitDisable bool + AutocommitGreedy bool + AutocommitInterval time.Duration + AutocommitMarks bool + Balancers []kgo.GroupBalancer + CommitCallback func(*kgo.Client, *kmsg.OffsetCommitRequest, *kmsg.OffsetCommitResponse, error) + Compression []kgo.CompressionCodec + ConnIdleTimeout time.Duration + DefaultProduceTopic string + DialFn func(context.Context, string, string) (net.Conn, error) + DisableFetchSessions bool + DisableIdempotency bool + Group string + HeartbeatInterval time.Duration + Hooks []kgo.Hook + ID string + InstanceID string + IsolationLevel int8 + KeepControl bool + Linger time.Duration + Logger kgo.Logger + ManualFlushing bool + MaxBrokerReadBytes int32 + MaxBrokerWriteBytes int32 + MaxBufferedRecords int + MaxBytes int32 + MaxConcurrentFetches int + MaxPartBytes int32 + MaxRecordBatchBytes int32 + MaxVersions *kversion.Versions + MaxWait time.Duration + MetadataMaxAge time.Duration + MetadataMinAge time.Duration + MinBytes int32 + MinVersions *kversion.Versions + OnAssigned func(context.Context, *kgo.Client, map[string][]int32) + OnDataLoss func(string, int32) + OnLost func(context.Context, *kgo.Client, map[string][]int32) + OnRevoked func(context.Context, *kgo.Client, map[string][]int32) + Options []kgo.Opt + Partitioner kgo.Partitioner + Partitions map[string]map[int32]kgo.Offset + ProduceTimeout time.Duration + Protocol string + Rack string + RebalanceTimeout time.Duration + RecordRetries int + RecordTimeout time.Duration + Regex bool + RequestTimeoutOverhead time.Duration + RequireStable bool + ResetOffset struct{ ... } + Retries int + RetryBackoff func(int) time.Duration + RetryTimeout time.Duration + Sasls []sasl.Mechanism + SeedBrokers []string + SessionTimeout time.Duration + SoftwareName string + SoftwareVersion string + StopOnDataLoss bool + Topics []string + TxnID string + TxnTimeout time.Duration + type Factory struct + func (k Factory) Make(name string) (*kgo.Client, error) + type Interceptor func(name string, config *Config) + type Maker interface + Make func(name string) (*kgo.Client, error) + type ProvidersOptionFunc func(options *providersOption) + func WithInterceptor(interceptor Interceptor) ProvidersOptionFunc + func WithReload(shouldReload bool) ProvidersOptionFunc
Go to main page