segmentio

README

Micro Broker Segmentio

Micro Broker Segmentio implementation.

DEPRECATION WARNING: not maintained, use go.unistack.org/micro-broker-kgo instead

License

Apache 2.0 licensed.

Documentation

Overview

Package kafka provides a kafka broker using segmentio

Index

• Variables
• func ClientID(id string) broker.Option
• func ClientPublishKey(key []byte) client.PublishOption
• func CommitInterval(td time.Duration) broker.Option
• func NewBroker(opts ...broker.Option) broker.Broker
• func PublishKey(key []byte) broker.PublishOption
• func ReaderConfig(c kafka.ReaderConfig) broker.Option
• func StatsInterval(td time.Duration) broker.Option
• func SubscribeContext(ctx context.Context) broker.SubscribeOption
• func SubscribeReaderConfig(c kafka.ReaderConfig) broker.SubscribeOption
• func SubscribeWriterConfig(c kafka.WriterConfig) broker.SubscribeOption
• func WriterCompletionFunc(fn func([]kafka.Message, error)) broker.Option
• func WriterConfig(c kafka.WriterConfig) broker.Option

Variables

var (
	DefaultReaderConfig    = kafka.ReaderConfig{}
	DefaultWriterConfig    = kafka.WriterConfig{}
	DefaultStatsInterval   = time.Second * 10
	DefaultCommitInterval  = time.Second * 0
	DefaultCommitQueueSize = 2000
)

Functions

func ClientID

func ClientID(id string) broker.Option

func ClientPublishKey

func ClientPublishKey(key []byte) client.PublishOption

func CommitInterval

func CommitInterval(td time.Duration) broker.Option

func NewBroker

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

func PublishKey

func PublishKey(key []byte) broker.PublishOption

func ReaderConfig

func ReaderConfig(c kafka.ReaderConfig) broker.Option

func StatsInterval

func StatsInterval(td time.Duration) 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 WriterCompletionFunc

func WriterCompletionFunc(fn func([]kafka.Message, error)) broker.Option

func WriterConfig

func WriterConfig(c kafka.WriterConfig) broker.Option