diff --git a/src/utils/json/mod.rs b/src/utils/json/mod.rs
index fd6992c72..9fb109552 100644
--- a/src/utils/json/mod.rs
+++ b/src/utils/json/mod.rs
@@ -38,7 +38,7 @@ pub fn flatten_json_body(
     let mut nested_value = if schema_version == SchemaVersion::V1
         && matches!(
             log_source,
-            LogSource::OtelLogs | LogSource::OtelMetrics | LogSource::OtelTraces
+            LogSource::Json | LogSource::Custom(_) | LogSource::Kinesis
         ) {
         flatten::generic_flattening(body)?
     } else {