Documentation ¶
Overview ¶
Package kafka provides a kafka broker using segmentio
Index ¶
- Variables
- func NewBroker(opts ...broker.Option) broker.Broker
- func ReaderConfig(c kafka.ReaderConfig) broker.Option
- func SubscribeContext(ctx context.Context) broker.SubscribeOption
- func SubscribeReaderConfig(c kafka.ReaderConfig) broker.SubscribeOption
- func SubscribeWriterConfig(c kafka.WriterConfig) broker.SubscribeOption
- func WriterConfig(c kafka.WriterConfig) broker.Option
Constants ¶
This section is empty.
Variables ¶
View Source
var ( DefaultReaderConfig = kafka.WriterConfig{} DefaultWriterConfig = kafka.ReaderConfig{} )
Functions ¶
func ReaderConfig ¶
func SubscribeContext ¶
func SubscribeContext(ctx context.Context) broker.SubscribeOption
SubscribeContext set the context for broker.SubscribeOption
func SubscribeReaderConfig ¶
func SubscribeReaderConfig(c kafka.ReaderConfig) broker.SubscribeOption
func SubscribeWriterConfig ¶
func SubscribeWriterConfig(c kafka.WriterConfig) broker.SubscribeOption
func WriterConfig ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.