Documentation
¶
Overview ¶
Package kafka 通用写kafka接口 Created by chenguolin 2018-09-21
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewSyncKafkaProducer ¶
func NewSyncKafkaProducer(brokers string) (*kafka.SyncProducer, error)
NewSyncKafkaProducer 实例化一个kafka producer
func WriteKafka ¶
func WriteKafka(producer *kafka.SyncProducer, topic, key, value string, retryTimes int) error
WriteKafka 写Kafka消息接口 kafkaProducer 生产者对象 topic 要写的topic key 消息key value 消息内容 retryTimes 重试次数
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.