broker

type Broker interface {
	Consumer(topic string, groupId string) *Consumer
	Producer() *Producer
}

type Consumer struct {
	*kafka.Reader
}

type Producer struct {
	*kafka.Writer
}