Versions in this module Expand all Collapse all v1 v1.3.0 Mar 14, 2018 Changes in this version + func GetProducer() (sarama.SyncProducer, error) + func Refresh() + type KafkaSender struct + func New() *KafkaSender + func (p *KafkaSender) Push(data map[string]interface{}) error + func (p *KafkaSender) SetTopic(topic string) v1.2.0 Sep 25, 2016
Go to main page