Documentation ¶ Index ¶ type Message type Producer func NewProducer(config *config.Configuration, partitioner string, partition int32, ...) (*Producer, error) func (p *Producer) Produce(topic string, wg *sync.WaitGroup) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Message ¶ type Message struct { Key []byte Value []byte } type Producer ¶ type Producer struct { // contains filtered or unexported fields } func NewProducer ¶ func NewProducer( config *config.Configuration, partitioner string, partition int32, input <-chan Message, ) (*Producer, error) func (*Producer) Produce ¶ func (p *Producer) Produce(topic string, wg *sync.WaitGroup) Source Files ¶ View all Source files produce.go Click to show internal directories. Click to hide internal directories.