consumer

Nov 13, 2018

Changes in this version

type Params

+ DeadlockCheckInterval time.Duration

+ MetricsFactory metrics.Factory

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