Categorygithub.com/uw-labs/substratekafka
package
0.0.0-20240327161656-5cd769b67f2b
Repository: https://github.com/uw-labs/substrate.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
16
Dependents
4
Files
669 SLOC

# Functions

No description provided by the author
No description provided by the author

# Constants

OffsetNewest indicates the next appropriate message available on the broker.
OffsetOldest indicates the oldest appropriate message available on the broker.

# Structs

No description provided by the author
AsyncMessageSource represents a kafka message source and implements the substrate.AsyncMessageSource interface.