kafka

Documentation

Index

• Constants
• Variables
• func GetKafkaClient() (sarama.ConsumerGroup, context.Context, error)
• func GetKafkaClientByGroupId(groupID string) (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 GetKafkaClientByGroupId

func GetKafkaClientByGroupId(groupID string) (sarama.ConsumerGroup, context.Context, error)

生成 kafka 消费实例

func GetkafkaProduct

func GetkafkaProduct() (sarama.SyncProducer, error)

生成 kafka 生产者实例