Interface Consumer

internal/queue/queue.go:22–25

Consumer defines the interface for Kafka message consumption

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

// Handler defines the interface for message processing
type Handler interface {