Documentation ¶ Index ¶ type Producer func New(client sarama.Client) (*Producer, error) func (p *Producer) Close() error func (p *Producer) SendKeyMessage(topic string, key, value []byte, h ...sarama.RecordHeader) error func (p *Producer) SendMessage(topic string, value []byte, h ...sarama.RecordHeader) error Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Producer ¶ type Producer struct { // contains filtered or unexported fields } func New ¶ func New(client sarama.Client) (*Producer, error) func (*Producer) Close ¶ func (p *Producer) Close() error func (*Producer) SendKeyMessage ¶ func (p *Producer) SendKeyMessage(topic string, key, value []byte, h ...sarama.RecordHeader) error func (*Producer) SendMessage ¶ func (p *Producer) SendMessage(topic string, value []byte, h ...sarama.RecordHeader) error Source Files ¶ View all Source files producer.go Click to show internal directories. Click to hide internal directories.