Struct ReaderFactory

otkafka/factory.go:13–15

ReaderFactory is a *di.Factory that creates *kafka.Reader. 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 ReaderFactory struct {
	*di.Factory
}

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