diff --git a/tfplan2cai/converters/google/resources/services/pubsub/pubsub_topic.go b/tfplan2cai/converters/google/resources/services/pubsub/pubsub_topic.go
index 74b35b626..6dbd83198 100644
--- a/tfplan2cai/converters/google/resources/services/pubsub/pubsub_topic.go
+++ b/tfplan2cai/converters/google/resources/services/pubsub/pubsub_topic.go
@@ -129,6 +129,13 @@ func expandPubsubTopicMessageStoragePolicy(v interface{}, d tpgresource.Terrafor
 		transformed["allowedPersistenceRegions"] = transformedAllowedPersistenceRegions
 	}
 
+	transformedEnforceInTransit, err := expandPubsubTopicMessageStoragePolicyEnforceInTransit(original["enforce_in_transit"], d, config)
+	if err != nil {
+		return nil, err
+	} else if val := reflect.ValueOf(transformedEnforceInTransit); val.IsValid() && !tpgresource.IsEmptyValue(val) {
+		transformed["enforceInTransit"] = transformedEnforceInTransit
+	}
+
 	return transformed, nil
 }
 
@@ -136,6 +143,10 @@ func expandPubsubTopicMessageStoragePolicyAllowedPersistenceRegions(v interface{
 	return v, nil
 }
 
+func expandPubsubTopicMessageStoragePolicyEnforceInTransit(v interface{}, d tpgresource.TerraformResourceData, config *transport_tpg.Config) (interface{}, error) {
+	return v, nil
+}
+
 func expandPubsubTopicSchemaSettings(v interface{}, d tpgresource.TerraformResourceData, config *transport_tpg.Config) (interface{}, error) {
 	l := v.([]interface{})
 	if len(l) == 0 || l[0] == nil {