producer

type KafkaProducerOpts struct {
	Brokers  string
	Topic    string
	MaxRetry int
}

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