kafka

Documentation

Index

• Variables
• func InitKafkaReader()
• func InitKafkaWriter()
• func Struct2Message(key string, st interface{}) (*kafka.Message, error)
• func WriteMessages(ctx context.Context, msgs ...kafka.Message) error

Variables

var KafkaReader *kafka.Reader

var KafkaWriter *kafka.Writer

Functions

func InitKafkaReader

func InitKafkaReader()

func InitKafkaWriter

func InitKafkaWriter()

make a writer that produces to topic-A, using the least-bytes distribution

func Struct2Message

func Struct2Message(key string, st interface{}) (*kafka.Message, error)

func WriteMessages

func WriteMessages(ctx context.Context, msgs ...kafka.Message) error