kafka

May 15, 2024

Changes in this version

+ type EventBus struct

+ func NewEventBus(addressList, appID string, options ...Option) (*EventBus, error)

+ func (b *EventBus) AddHandler(ctx context.Context, m eh.EventMatcher, h eh.EventHandler) error

+ func (b *EventBus) Close() error

+ func (b *EventBus) Errors() <-chan error

+ func (b *EventBus) HandleEvent(ctx context.Context, event eh.Event) error

+ func (b *EventBus) HandlerType() eh.EventHandlerType

+ type Option func(*EventBus) error

+ func WithAutoCreateTopic(autoCreate bool) Option

+ func WithCodec(codec eh.EventCodec) Option

+ func WithStartOffset(startOffset int64) Option

+ func WithTopic(topic string) Option

+ func WithTopicPartitions(numPartitions int) Option