diff --git a/src/plugins/home/server/services/sample_data/usage/collector_fetch.test.ts b/src/plugins/home/server/services/sample_data/usage/collector_fetch.test.ts
index 54fed3db1de4d2..58bb037f8d614e 100644
--- a/src/plugins/home/server/services/sample_data/usage/collector_fetch.test.ts
+++ b/src/plugins/home/server/services/sample_data/usage/collector_fetch.test.ts
@@ -23,7 +23,7 @@ import { fetchProvider } from './collector_fetch';
 
 const getMockFetchClients = (hits?: unknown[]) => {
   const fetchParamsMock = createCollectorFetchContextMock();
-  fetchParamsMock.callCluster.mockResolvedValue({ hits: { hits } });
+  fetchParamsMock.esClient.search = jest.fn().mockResolvedValue({ body: { hits: { hits } } });
   return fetchParamsMock;
 };
 
diff --git a/src/plugins/home/server/services/sample_data/usage/collector_fetch.ts b/src/plugins/home/server/services/sample_data/usage/collector_fetch.ts
index 7df9b14d2efb18..ef958873d96632 100644
--- a/src/plugins/home/server/services/sample_data/usage/collector_fetch.ts
+++ b/src/plugins/home/server/services/sample_data/usage/collector_fetch.ts
@@ -19,6 +19,7 @@
 
 import { get } from 'lodash';
 import moment from 'moment';
+import { SearchResponse } from 'src/core/server';
 import { CollectorFetchContext } from '../../../../../usage_collection/server';
 
 interface SearchHit {
@@ -41,17 +42,23 @@ export interface TelemetryResponse {
   last_uninstall_set: string | null;
 }
 
+type ESResponse = SearchResponse<SearchHit>;
+
 export function fetchProvider(index: string) {
-  return async ({ callCluster }: CollectorFetchContext) => {
-    const response = await callCluster('search', {
-      index,
-      body: {
-        query: { term: { type: { value: 'sample-data-telemetry' } } },
-        _source: { includes: ['sample-data-telemetry', 'type', 'updated_at'] },
+  return async ({ esClient }: CollectorFetchContext) => {
+    const { body: response } = await esClient.search<ESResponse>(
+      {
+        index,
+        body: {
+          query: { term: { type: { value: 'sample-data-telemetry' } } },
+          _source: { includes: ['sample-data-telemetry', 'type', 'updated_at'] },
+        },
+        filter_path: 'hits.hits._id,hits.hits._source',
       },
-      filter_path: 'hits.hits._id,hits.hits._source',
-      ignore: [404],
-    });
+      {
+        ignore: [404],
+      }
+    );
 
     const getLast = (
       dataSet: string,