package
0.3.0
Repository: https://github.com/katallaxie/streams.git
Documentation: pkg.go.dev

# Functions

DefaultOpts is the default options for a kafka source.
WithBufferSize configures the buffer size for a kafka source.
WithContext is a constructor for a kafka source with a cancellation context.

# Constants

CommitAuto commits messages automatically.
CommitManual commits messages manually.

# Structs

Opts is a set of options for a kafka source.
Source is a Kafka source.

# Type aliases

CommitMode is a Kafka source commit mode.
Opt is a Kafka source option.