Categorygithub.com/gregoryfranklin/jaegercmdingesterappconsumer
package
1.9.0
Repository: https://github.com/gregoryfranklin/jaeger.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
15
Dependents
0
Files
489 SLOC

# Packages

No description provided by the author
No description provided by the author

# Functions

New is a constructor for a Consumer.
NewCommittingProcessor returns a processor that commits message offsets to Kafka.
NewProcessorFactory constructs a new ProcessorFactory.

# Structs

Consumer uses sarama to consume and handle messages from kafka.
Params are the parameters of a Consumer.
ProcessorFactory is a factory for creating startedProcessors.
ProcessorFactoryParams are the parameters of a ProcessorFactory.

# Interfaces

Message contains the parts of a sarama ConsumerMessage that we care about.