consumer

type Consumer interface {
	Start(ctx context.Context)
	RegisterHandler(handler EventHandler)
	Close()
}

type EventHandler interface {
	Name() string
	Handle(ctx context.Context, event map[string]interface{}) error
}

type KafkaConsumerOpts struct {
	Brokers  string
	GroupID  string
	Topic    string
	MinBytes int
	MaxBytes int
	MaxRetry int
}