type ProducerSerializer = Serializer<OutgoingEvent | OutgoingRequest, any>;