Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CommitMode ¶ added in v0.2.1
type CommitMode int
CommitMode is a Kafka source commit mode.
const ( // CommitAuto commits messages automatically. CommitAuto CommitMode = iota // CommitManual commits messages manually. CommitManual )
type Opt ¶ added in v0.2.1
type Opt func(o *Opts)
Opt is a Kafka source option.
func WithBufferSize ¶ added in v0.2.1
WithBufferSize configures the buffer size for a kafka source.
type Opts ¶ added in v0.2.1
type Opts struct {
// contains filtered or unexported fields
}
Opts is a set of options for a kafka source.
func DefaultOpts ¶ added in v0.2.1
func DefaultOpts() *Opts
DefaultOpts is the default options for a kafka source.
type Source ¶
type Source[K, V any] struct { // contains filtered or unexported fields }
Source is a Kafka source.
func WithContext ¶
func WithContext[K, V any](ctx context.Context, r *kgo.Reader, key codec.Decoder[K], value codec.Decoder[V], keyEncoder codec.Encoder[K], opts ...Opt) *Source[K, V]
WithContext is a constructor for a kafka source with a cancellation context.
Source Files
Click to show internal directories.
Click to hide internal directories.