producer

Documentation

Index

• type Message
• type Producer
  • func NewProducer(config config.Config, partitioner string, partition int32, ...) (*Producer, error)
  • func (p *Producer) Produce(topic string, wg *sync.WaitGroup)

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.Config,
	partitioner string,
	partition int32,
	input <-chan Message,
) (*Producer, error)

func (*Producer) Produce

func (p *Producer) Produce(topic string, wg *sync.WaitGroup)