Struct WriterFactory

otkafka/factory.go:31–33

WriterFactory is a *di.Factory that creates *kafka.Writer. Unlike other database providers, the kafka factories don't bundle a default kafka reader/writer. It is suggested to use Topic name as the identifier of kafka config rather than an opaque name such as default.

// kafka reader/writer. It is suggested to use Topic name as the identifier of
// kafka config rather than an opaque name such as default.
type WriterFactory struct {
	*di.Factory
}

// Make returns a *kafka.Writer under the provided configuration entry.
func (k WriterFactory) Make(name string) (*kafka.Writer, error) {