consumer

Documentation

Index

• type ConsumerRunner
  • func KafkaConsumerInit(config *config.Config, key *util.MsgKey, context *util.Context) (*ConsumerRunner, error)
  • func (consumer *ConsumerRunner) Sub()

Types

type ConsumerRunner

type ConsumerRunner struct {
	Runner   *kafka.Consumer
	Topic    string
	MsgCount int
	Key      string
	Context  *util.Context
}

func KafkaConsumerInit

func KafkaConsumerInit(config *config.Config, key *util.MsgKey, context *util.Context) (*ConsumerRunner, error)

func (*ConsumerRunner) Sub

func (consumer *ConsumerRunner) Sub()