Method Subscribe

internal/queue/queue.go:23–23

(topics []string)

// Consumer defines the interface for Kafka message consumption
type Consumer interface {
	Subscribe(topics []string) error
	Close() error
}