writer

Feb 25, 2023

Changes in this version

+ func DefaultConfig() *kafka.Writer

Feb 20, 2023

Changes in this version

+ func NewWriter(opts ...Opt) *kafka.Writer

+ type Opt func(*kafka.Writer)

+ func WithBalancer(b kafka.Balancer) Opt

+ func WithBatchSize(batchSize int) Opt

+ func WithBatchTimeout(timeout time.Duration) Opt

+ func WithBrokers(brokers ...string) Opt

+ func WithTopic(topic string) Opt

+ func WithTransport(transport *kafka.Transport) Opt

+ type Writer interface

+ Close func() error

+ Stats func() kafka.WriterStats

+ WriteMessages func(ctx context.Context, msgs ...kafka.Message) error