diff --git a/kpops/components/base_components/helm_app.py b/kpops/components/base_components/helm_app.py
index f91a164cc..94fa3e8cd 100644
--- a/kpops/components/base_components/helm_app.py
+++ b/kpops/components/base_components/helm_app.py
@@ -209,10 +209,3 @@ def print_helm_diff(self, stdout: str) -> None:
     @model_serializer(mode="wrap", when_used="always")
     def serialize_model(self, handler, info: SerializationInfo) -> dict[str, Any]:
         return exclude_by_name(handler(self), "helm", "helm_diff")
-
-    async def fetch_values_from_cluster(self) -> dict[str, Any] | None:
-        """Fetch the released streams-bootstrap values from the cluster using the 'helm get values' command.
-
-        :return: dict of Helm values or None if no release was found
-        """
-        return await self.helm.get_values(self.namespace, self.helm_release_name)
diff --git a/kpops/components/base_components/kafka_app.py b/kpops/components/base_components/kafka_app.py
index f0ed87ff2..7dd6b954b 100644
--- a/kpops/components/base_components/kafka_app.py
+++ b/kpops/components/base_components/kafka_app.py
@@ -119,7 +119,9 @@ async def clean(self, dry_run: bool) -> None:
 
     async def update_cleaner_with_cluster_values(self) -> None:
         """Update cleaner with cluster values if the release exists."""
-        cluster_values = await self.fetch_values_from_cluster()
+        cluster_values = await self.helm.get_values(
+            self.namespace, self.helm_release_name
+        )
         if cluster_values:
             self.app = self.app.__class__.model_validate(cluster_values)
             self.app.name_override = self.helm_name_override