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.

CommitAuto commits messages automatically.

CommitManual commits messages manually.

Opts is a set of options for a kafka source.

Source is a Kafka source.

CommitMode is a Kafka source commit mode.

Opt is a Kafka source option.