kafka

Documentation

Index

• Constants
• Variables
• func GetKafkaClient() (sarama.ConsumerGroup, context.Context, error)
• func GetkafkaProduct() (sarama.SyncProducer, error)

Constants

const GolLogTopic = "global_log"

Variables

var (
	KafkaClient  sarama.ConsumerGroup
	KafkaProduct sarama.SyncProducer
)

Functions

func GetKafkaClient

func GetKafkaClient() (sarama.ConsumerGroup, context.Context, error)

生成 kafka 消费实例

func GetkafkaProduct

func GetkafkaProduct() (sarama.SyncProducer, error)

生成 kafka 生产者实例