mq

Documentation

Index

• func Close()
• func InitKafka(kafkaAddrs []string) (err error)
• func PushKafka(topic string, value string) (err error)
• type KafkaConsumer
  • func (kc *KafkaConsumer) InitKafkaConsumer(prehookF func(), handleF func(string), posthookF func()) error

Functions

func Close

func Close()

Close close

func InitKafka

func InitKafka(kafkaAddrs []string) (err error)

InitKafka init kafka

func PushKafka

func PushKafka(topic string, value string) (err error)

PushKafka push kafka

Types

type KafkaConsumer

type KafkaConsumer struct {
	Topic             string
	GoupName          string
	ZKRoot            string
	ZKAddrs           []string
	ProcessingTimeout time.Duration
	CommitInterval    time.Duration
}

KafkaConsumer kafka consumer

func (*KafkaConsumer) InitKafkaConsumer

func (kc *KafkaConsumer) InitKafkaConsumer(prehookF func(), handleF func(string), posthookF func()) error

InitKafkaConsumer run