producer

Documentation

Index

• func WithSeedBrokers(hosts ...string) func(*Producer)
• func WithTopic(topic string) func(*Producer)
• type Producer
  • func NewProducer(options ...func(*Producer)) (*Producer, error)
  • func (p *Producer) Produce(ctx context.Context, payload []byte) error
  • func (p *Producer) ProduceWithHeaders(ctx context.Context, payload []byte, headers map[string][]byte) error

Functions

func WithSeedBrokers

func WithSeedBrokers(hosts ...string) func(*Producer)

func WithTopic

func WithTopic(topic string) func(*Producer)

Types

type Producer

type Producer struct {
	// contains filtered or unexported fields
}

func NewProducer

func NewProducer(options ...func(*Producer)) (*Producer, error)

func (*Producer) Produce

func (p *Producer) Produce(ctx context.Context, payload []byte) error

func (*Producer) ProduceWithHeaders

func (p *Producer) ProduceWithHeaders(ctx context.Context, payload []byte, headers map[string][]byte) error