producer

type KafkaProducerOpts struct {
	Brokers    string
	Topic      string
	MaxRetry   int
	SASLConfig *KafkaSASLOpts
}

type KafkaSASLOpts struct {
	Username string
	Password string
}

type Producer interface {
	Produce(ctx context.Context, payload interface{}) (err error)
	Close()
}