Versions in this module Expand all Collapse all v0 v0.7.0 Jul 23, 2026 Changes in this version + type Consumer interface + Commit func(ctx context.Context) error + Ping func(ctx context.Context) error + Poll func(ctx context.Context) ([]*event.Event, error) + type Publisher interface + Ping func(ctx context.Context) error + Publish func(ctx context.Context, event *event.Event) error
Go to main page