kafka

Documentation

Index

• Constants
• func InitKafka(kafkaAddrs []string) (err error)
• func MSGpushKafka(msg interface{}) (err error)
• type KafkaMsg

Constants

const (
	KafkaPushsTopic = "sj_chat"
)

Functions

func InitKafka

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

func MSGpushKafka

func MSGpushKafka(msg interface{}) (err error)

Types

type KafkaMsg

type KafkaMsg struct {
}