diff --git a/lib/internal/modules/esm/fetch_module.js b/lib/internal/modules/esm/fetch_module.js
index 21b7456899604fe..c08645554b9e9da 100644
--- a/lib/internal/modules/esm/fetch_module.js
+++ b/lib/internal/modules/esm/fetch_module.js
@@ -138,15 +138,16 @@ function isRedirect(statusCode) {
  * @param {URL} parsed
  * @returns {Promise<CacheEntry> | CacheEntry}
  */
-function fetchWithRedirects(parsed) {
+function fetchWithRedirects(parsed, context) {
   const existing = cacheForGET.get(parsed.href);
   if (existing) {
     return existing;
   }
   const handler = parsed.protocol === 'http:' ? HTTPGet : HTTPSGet;
   const result = (async () => {
+    const type = context.importAssertions?.type;
     const req = handler(parsed, {
-      headers: { Accept: '*/*' },
+      headers: { Accept: type === 'json' ? 'application/json,*/*;q=0.5' : '*/*;' },
     });
     // Note that `once` is used here to handle `error` and that it hits the
     // `finally` on network error/timeout.
@@ -162,7 +163,7 @@ function fetchWithRedirects(parsed) {
             'cannot redirect to non-network location',
           );
         }
-        const entry = await fetchWithRedirects(location);
+        const entry = await fetchWithRedirects(location, context);
         cacheForGET.set(parsed.href, entry);
         return entry;
       }
@@ -262,7 +263,8 @@ async function isLocalAddress(hostname) {
  * @param {ESModuleContext} context
  * @returns {ReturnType<typeof fetchWithRedirects>}
  */
-function fetchModule(parsed, { parentURL }) {
+function fetchModule(parsed, context) {
+  const { parentURL } = context;
   const { href } = parsed;
   const existing = cacheForGET.get(href);
   if (existing) {
@@ -277,10 +279,10 @@ function fetchModule(parsed, { parentURL }) {
           'http can only be used to load local resources (use https instead).',
         );
       }
-      return fetchWithRedirects(parsed);
+      return fetchWithRedirects(parsed, context);
     });
   }
-  return fetchWithRedirects(parsed);
+  return fetchWithRedirects(parsed, context);
 }
 
 module.exports = {
diff --git a/test/es-module/test-http-imports.mjs b/test/es-module/test-http-imports.mjs
index 235d142d3555e30..8a19c00b0b413a6 100644
--- a/test/es-module/test-http-imports.mjs
+++ b/test/es-module/test-http-imports.mjs
@@ -68,6 +68,11 @@ for (const { protocol, createServer } of [
     const server = createServer(function(_req, res) {
       const url = new URL(_req.url, host);
       const redirect = url.searchParams.get('redirect');
+
+      if (url.pathname === 'json') {
+        common.mustCall(() => assert.strictEqual(_req.header.content, 'application/json,*/*;q=0.5'));
+      }
+
       if (url.pathname === '/not-found') {
         res.writeHead(404);
         res.end();
@@ -204,6 +209,13 @@ for (const { protocol, createServer } of [
       { code: 'ERR_MODULE_NOT_FOUND' },
     );
 
+    const jsonUrl = new URL(url.href + 'json');
+    jsonUrl.searchParams.set('mime', 'application/json');
+    jsonUrl.searchParams.set('body', '{"x": 1}');
+    const json = await import(jsonUrl.href, { assert: { type: 'json' } });
+    assert.deepStrictEqual(Object.keys(json), ['default']);
+    assert.strictEqual(json.default.x, 1);
+
     server.close();
   }
 }