diff --git a/src/protocol/requests/metadata/v1/request.js b/src/protocol/requests/metadata/v1/request.js
index 61b2446ae..9dc4911fc 100644
--- a/src/protocol/requests/metadata/v1/request.js
+++ b/src/protocol/requests/metadata/v1/request.js
@@ -1,8 +1,16 @@
-const requestV0 = require('../v0/request')
+const Encoder = require('../../../encoder')
+const { Metadata: apiKey } = require('../../apiKeys')
 
 /**
  * Metadata Request (Version: 1) => [topics]
  *   topics => STRING
  */
 
-module.exports = ({ topics }) => Object.assign(requestV0({ topics }), { apiVersion: 1 })
+module.exports = ({ topics }) => ({
+  apiKey,
+  apiVersion: 1,
+  apiName: 'Metadata',
+  encode: async () => {
+    return new Encoder().writeNullableArray(topics)
+  },
+})
diff --git a/src/protocol/requests/metadata/v2/request.js b/src/protocol/requests/metadata/v2/request.js
index 77ad4d3ee..9d7f55e31 100644
--- a/src/protocol/requests/metadata/v2/request.js
+++ b/src/protocol/requests/metadata/v2/request.js
@@ -1,8 +1,8 @@
-const requestV0 = require('../v0/request')
+const requestV1 = require('../v1/request')
 
 /**
  * Metadata Request (Version: 2) => [topics]
  *   topics => STRING
  */
 
-module.exports = ({ topics }) => Object.assign(requestV0({ topics }), { apiVersion: 2 })
+module.exports = ({ topics }) => Object.assign(requestV1({ topics }), { apiVersion: 2 })
diff --git a/src/protocol/requests/metadata/v3/request.js b/src/protocol/requests/metadata/v3/request.js
index 460ec04aa..b5936bfe7 100644
--- a/src/protocol/requests/metadata/v3/request.js
+++ b/src/protocol/requests/metadata/v3/request.js
@@ -1,8 +1,8 @@
-const requestV0 = require('../v0/request')
+const requestV1 = require('../v1/request')
 
 /**
  * Metadata Request (Version: 3) => [topics]
  *   topics => STRING
  */
 
-module.exports = ({ topics }) => Object.assign(requestV0({ topics }), { apiVersion: 3 })
+module.exports = ({ topics }) => Object.assign(requestV1({ topics }), { apiVersion: 3 })