Versions in this module Expand all Collapse all v0 v0.0.1 Dec 24, 2025 Changes in this version + type Config struct + Kafka mq.KafkaConfig + type Consumer struct + func NewConsumer(memory *action.Memory, cfg Config) (*Consumer, error) + func (c *Consumer) Start(ctx context.Context) error + func (c *Consumer) Stop() error
Go to main page