Versions in this module Expand all Collapse all v1 v1.7.0 Sep 19, 2018 Changes in this version + func NewCommittingProcessor(processor processor.SpanProcessor, marker offsetMarker) processor.SpanProcessor + type Consumer struct + func New(params Params) (*Consumer, error) + func (c *Consumer) Close() error + func (c *Consumer) Start() + type Message interface + Key func() []byte + Offset func() int64 + Partition func() int32 + Topic func() string + Value func() []byte + type Params struct + Factory metrics.Factory + InternalConsumer consumer.Consumer + Logger *zap.Logger + ProcessorFactory ProcessorFactory + type ProcessorFactory struct + func NewProcessorFactory(params ProcessorFactoryParams) (*ProcessorFactory, error) + type ProcessorFactoryParams struct + BaseProcessor processor.SpanProcessor + Factory metrics.Factory + Logger *zap.Logger + Parallelism int + SaramaConsumer consumer.Consumer + Topic string
Go to main page