Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SeqConsumer ¶
type SeqConsumer struct { ConsumerGrp sarama.ConsumerGroup // contains filtered or unexported fields }
SeqConsumer represents the consumer that recieves the sequenced messages
func NewConsumer ¶
func NewConsumer(cfg *config.Config) (*SeqConsumer, error)
NewConsumer returns a new OrderedSeqConsumer
Click to show internal directories.
Click to hide internal directories.