kafka

README

Kafka

Documentation

Index

• Variables
• func NewBroker(opts ...broker.Option) broker.Broker
• func WithReaderConfig(c kafka.ReaderConfig) broker.Option
• func WithSubscribeContext(ctx context.Context) broker.SubscribeOption
• func WithSubscribeContextFromContext(ctx context.Context) (context.Context, bool)
• func WithSubscribeReaderConfig(c kafka.ReaderConfig) broker.SubscribeOption
• func WithSubscribeWriterConfig(c kafka.WriterConfig) broker.SubscribeOption
• func WithWriterConfig(c kafka.WriterConfig) broker.Option

Variables

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

Functions

func NewBroker

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

func WithReaderConfig

func WithReaderConfig(c kafka.ReaderConfig) broker.Option

func WithSubscribeContext

func WithSubscribeContext(ctx context.Context) broker.SubscribeOption

func WithSubscribeContextFromContext

func WithSubscribeContextFromContext(ctx context.Context) (context.Context, bool)

func WithSubscribeReaderConfig

func WithSubscribeReaderConfig(c kafka.ReaderConfig) broker.SubscribeOption

func WithSubscribeWriterConfig

func WithSubscribeWriterConfig(c kafka.WriterConfig) broker.SubscribeOption

func WithWriterConfig

func WithWriterConfig(c kafka.WriterConfig) broker.Option