Versions in this module Expand all Collapse all v0 v0.0.0 Nov 23, 2022 Changes in this version + type Option interface + func WithErrorHandler(errorHandler func(error)) Option + func WithFlushInterval(interval time.Duration) Option + func WithMaxRetries(maxRetries int) Option + func WithVersion(version sarama.KafkaVersion) Option + type Producer struct + func NewProducer(brokers []string, opts ...Option) (*Producer, error) + func (p *Producer) Close() error + func (p *Producer) Produce(ctx context.Context, topic string, key []byte, msg []byte) error + func (p *Producer) Run()
Go to main page