Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCommittingProcessor ¶
func NewCommittingProcessor(processor processor.SpanProcessor, marker offsetMarker) processor.SpanProcessor
NewCommittingProcessor returns a processor that commits message offsets to Kafka
Types ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
Consumer uses sarama to consume and handle messages from kafka
type Message ¶
type Message interface {
Key() []byte
Value() []byte
Topic() string
Partition() int32
Offset() int64
}
Message contains the parts of a sarama ConsumerMessage that we care about.
type Params ¶
type Params struct {
ProcessorFactory ProcessorFactory
MetricsFactory metrics.Factory
Logger *zap.Logger
InternalConsumer consumer.Consumer
DeadlockCheckInterval time.Duration
}
Params are the parameters of a Consumer
type ProcessorFactory ¶
type ProcessorFactory struct {
// contains filtered or unexported fields
}
ProcessorFactory is a factory for creating startedProcessors
func NewProcessorFactory ¶
func NewProcessorFactory(params ProcessorFactoryParams) (*ProcessorFactory, error)
NewProcessorFactory constructs a new ProcessorFactory
Source Files
¶
Click to show internal directories.
Click to hide internal directories.