kafka

Documentation

Index

• func InitConsumer(name string, addresses []string, topic, kafkaVersion, consumerName string)
• func InitProducer(name string, addresses []string)
• func KConsume(ctx context.Context, name, topic string, fn func([]byte) error) error
• func SendKMsg(name string, msg *Msg) error
• type Msg

Functions

func InitConsumer

func InitConsumer(name string, addresses []string, topic, kafkaVersion, consumerName string)

初始化Kafka消费者

func InitProducer

func InitProducer(name string, addresses []string)

初始化Kafka生产者

func KConsume

func KConsume(ctx context.Context, name, topic string, fn func([]byte) error) error

func SendKMsg

func SendKMsg(name string, msg *Msg) error

Types

type Msg

type Msg struct {
	Key   string
	Topic string
	Data  interface{}
}