mq

type Consumer interface {
	ReceiveAndHandle(h KafkaHandler) error
}

type ConsumerConfig struct {
	Brokers []string
	Topic   string
	GroupID string
	Debug   bool
}

type KafkaHandler interface {
	Handle(ctx context.Context, msg *Message) error
}

type Message = kafka.Message

type Producer interface {
	Publish(ctx context.Context, key, payload []byte) error
}

type ProducerConfig struct {
	Brokers []string
	Topic   string
	Debug   bool
}