producer

package

v0.0.0-...-440ad23 Latest Latest Go to latest Published: Dec 3, 2024 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type CreateOptions struct {
	NumPartitions     int
	ReplicationFactor int
}

type Option func(conf *conf)

func WithBalancer(balancer kafka.Balancer) Option

func WithCreateTopic(numPartitions, replicationFactor int) Option

func WithCredentials(algo, user, password, cert string) Option

func WithLog() Option

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

func New(ctx context.Context, hosts []string, topic string, options ...Option) (*Producer, error)

func (p *Producer) Close() error

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