consumer

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

type Event struct {
	ID        uuid.UUID   `json:"id"`
	PartyID   uuid.UUID   `json:"party_id"`
	Type      string      `json:"type"`
	Publisher string      `json:"publisher"`
	Payload   interface{} `json:"payload"`
}

type EventHandler interface {
	Name() string
	Handle(ctx context.Context, event *Event) error
}

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