segmentio

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

Variables

var (
	DefaultReaderConfig = kafka.WriterConfig{}
	DefaultWriterConfig = kafka.ReaderConfig{}
)

Functions

func NewBroker

func NewBroker(opts ...broker.Option) broker.Broker

func ReaderConfig

func ReaderConfig(c kafka.ReaderConfig) broker.Option

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

func WriterConfig(c kafka.WriterConfig) broker.Option