kafka

type Consumer interface {
	Run()
}

type Handler interface {
	Handle(context.Context, kafka_client.Message) error
}

type Settings struct {
	Brokers      []string
	Topic        string
	GroupID      string
	Timeout      time.Duration
	RetryTimeout time.Duration
	RetryCount   int8
}