Versions in this module Expand all Collapse all v1 v1.0.0 Nov 1, 2024 Changes in this version + func WrapAsyncProducer(saramaConfig *sarama.Config, p sarama.AsyncProducer, opts ...Option) sarama.AsyncProducer + func WrapConsumer(c sarama.Consumer, opts ...Option) sarama.Consumer + func WrapPartitionConsumer(pc sarama.PartitionConsumer, opts ...Option) sarama.PartitionConsumer + func WrapSyncProducer(saramaConfig *sarama.Config, producer sarama.SyncProducer, opts ...Option) sarama.SyncProducer + type ConsumerMessageCarrier struct + func NewConsumerMessageCarrier(msg *sarama.ConsumerMessage) ConsumerMessageCarrier + func (c ConsumerMessageCarrier) ForeachKey(handler func(key, val string) error) error + func (c ConsumerMessageCarrier) Set(key, val string) + type Option func(cfg *config) + func WithAnalytics(on bool) Option + func WithAnalyticsRate(rate float64) Option + func WithDataStreams() Option + func WithGroupID(groupID string) Option + func WithServiceName(name string) Option + type ProducerMessageCarrier struct + func NewProducerMessageCarrier(msg *sarama.ProducerMessage) ProducerMessageCarrier + func (c ProducerMessageCarrier) ForeachKey(handler func(key, val string) error) error + func (c ProducerMessageCarrier) Set(key, val string)
Go to main page