Versions in this module Expand all Collapse all v0 v0.1.1 Dec 6, 2025 v0.1.0 Dec 6, 2025 Changes in this version + var ConsumerModule = fx.Module("kafka-consumer", fx.Provide(NewConfig, NewKafkaConsumer, ...), ...) + func RunConsumer(p ConsumerParams, consumer *KafkaConsumer) + type Config struct + Brokers []string + GroupID string + MaxBytes int + MaxWait time.Duration + MinBytes int + Topic string + func NewConfig(v *viper.Viper) *Config + type ConsumerParams struct + Config *Config + Handler messaging.Handler + Lifecycle fx.Lifecycle + Logger log.Logger + type KafkaConsumer struct + func NewKafkaConsumer(cfg *Config, handler messaging.Handler, logger log.Logger) *KafkaConsumer + func (c *KafkaConsumer) Start(ctx context.Context) error + func (c *KafkaConsumer) Stop(ctx context.Context) error
Go to main page