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
	SASLConfig *KafkaSASLOpts
}

type KafkaSASLOpts struct {
	Username string
	Password string
}