diff --git a/metadata-ingestion/src/datahub/ingestion/source/kafka.py b/metadata-ingestion/src/datahub/ingestion/source/kafka.py
index 0523ec24ebf04..53977c5e96c7e 100644
--- a/metadata-ingestion/src/datahub/ingestion/source/kafka.py
+++ b/metadata-ingestion/src/datahub/ingestion/source/kafka.py
@@ -208,7 +208,6 @@ def __init__(self, config: KafkaSourceConfig, ctx: PipelineContext):
             self.source_config.tag_prefix,
             OwnershipSourceTypeClass.SERVICE,
             self.source_config.strip_user_ids_from_email,
-            match_nested_props=True,
         )
 
     def init_kafka_admin_client(self) -> None:
diff --git a/metadata-ingestion/tests/unit/test_mapping.py b/metadata-ingestion/tests/unit/test_mapping.py
index 078c79ab5a9b7..d8a430c7167d6 100644
--- a/metadata-ingestion/tests/unit/test_mapping.py
+++ b/metadata-ingestion/tests/unit/test_mapping.py
@@ -329,7 +329,6 @@ def test_operation_processor_matching_dot_props():
             },
         },
         owner_source_type="SOURCE_CONTROL",
-        match_nested_props=True,
     )
     aspect_map = processor.process(raw_props)
     assert "add_tag" in aspect_map