events

type CastsRepository interface {
	DeleteCast(ctx context.Context, id int32) error
	RemovePersonFromCasts(ctx context.Context, personID int32) (err error)
}

type KafkaReaderConfig struct {
	Brokers          []string
	GroupID          string
	ReadBatchTimeout time.Duration
}

type KafkaWriterConfig struct {
	Brokers []string
}