Versions in this module Expand all Collapse all v3 v3.0.0 Dec 3, 2020 Changes in this version + func TopicFromContext(ctx context.Context) (string, bool) + type CfgOption func(config *sarama.Config) + func FromNewest() CfgOption + type Consumer struct + func New(kafkaBrokers []string, consumerGroupID string, topics []string, ...) (*Consumer, error) + func (c *Consumer) AddFallback(fn FallbackFunc) + func (c *Consumer) AddHandler(messageType string, handler handler.Handler) + func (c *Consumer) HealthCheck(_ context.Context) bool + func (c *Consumer) Start(ctx context.Context) error + type FallbackFunc func(context.Context, []byte) error
Go to main page