Documentation ¶
Index ¶
Constants ¶
View Source
const DefaultIntervalSecs = 60
Variables ¶
View Source
var DefaultKafkaVersion = sarama.V0_10_0_0
Functions ¶
This section is empty.
Types ¶
type MsgProducer ¶
type Producer ¶
type Producer struct {
sarama.SyncProducer
}
func NewProducer ¶
func NewProducer(cfg *ProducerCfg) (*Producer, error)
type ProducerCfg ¶
Click to show internal directories.
Click to hide internal directories.