Versions in this module Expand all Collapse all v1 v1.0.0 Feb 21, 2024 Changes in this version + var ErrCommitFailed = errors.New("kafka: failed to commit offsets") + type CommonConfig struct + Brokers []string + ClientID string + ConfigFile string + Dialer func(ctx context.Context, network, address string) (net.Conn, error) + DisableTelemetry bool + Logger *zap.Logger + MeterProvider metric.MeterProvider + Namespace string + SASL SASLMechanism + TLS *tls.Config + TracerProvider trace.TracerProvider + Version string + type CompressionCodec = kgo.CompressionCodec + func GzipCompression() CompressionCodec + func Lz4Compression() CompressionCodec + func NoCompression() CompressionCodec + func SnappyCompression() CompressionCodec + func ZstdCompression() CompressionCodec + type Consumer struct + func NewConsumer(cfg ConsumerConfig) (*Consumer, error) + func (c *Consumer) Close() error + func (c *Consumer) Healthy(ctx context.Context) error + func (c *Consumer) Run(ctx context.Context) error + type ConsumerConfig struct + ConsumeRegex bool + Delivery apmqueue.DeliveryType + GroupID string + MaxConcurrentFetches int + MaxPollBytes int32 + MaxPollPartitionBytes int32 + MaxPollRecords int + MaxPollWait time.Duration + Processor apmqueue.Processor + ShutdownGracePeriod time.Duration + Topics []apmqueue.Topic + type Manager struct + func NewManager(cfg ManagerConfig) (*Manager, error) + func (m *Manager) Close() error + func (m *Manager) DeleteTopics(ctx context.Context, topics ...apmqueue.Topic) error + func (m *Manager) Healthy(ctx context.Context) error + func (m *Manager) MonitorConsumerLag(topicConsumers []apmqueue.TopicConsumer) (metric.Registration, error) + func (m *Manager) NewTopicCreator(cfg TopicCreatorConfig) (*TopicCreator, error) + type ManagerConfig struct + type Producer struct + func NewProducer(cfg ProducerConfig) (*Producer, error) + func (p *Producer) Close() error + func (p *Producer) Healthy(ctx context.Context) error + func (p *Producer) Produce(ctx context.Context, rs ...apmqueue.Record) error + type ProducerConfig struct + CompressionCodec []CompressionCodec + ManualFlushing bool + MaxBufferedRecords int + ProducerBatchMaxBytes int32 + Sync bool + type SASLMechanism = sasl.Mechanism + type TopicCreator struct + func (c *TopicCreator) CreateTopics(ctx context.Context, topics ...apmqueue.Topic) error + type TopicCreatorConfig struct + MeterProvider metric.MeterProvider + PartitionCount int + TopicConfigs map[string]string + func (cfg TopicCreatorConfig) Validate() error Other modules containing this package github.com/elastic/apm-queue/v2
Go to main page