Make error messages from the server available

Many APIs return error codes and error messages in case of errors.
Previously, only error codes have been handled which were used to
construct generic protocol errors with predefined error messages.
Error messages from the Kafka cluster were skipped altogether. This
PR makes the error messages from the Kafka cluster available inside
the protocol errors if those have been provided. This way, more detailed
information about the issue can be accessed.

Author: lp247

src/apis/admin/alter-client-quotas-v1.ts

@@ -106,7 +106,7 @@ export function parseResponse (
       }
 
       if (entry.errorCode !== 0) {
-        errors.push([`/entries/${i}`, entry.errorCode])
+        errors.push([`/entries/${i}`, [entry.errorCode, entry.errorMessage]])
       }
 
       return entry

src/apis/admin/alter-configs-v2.ts

@@ -73,14 +73,15 @@ export function parseResponse (
     throttleTimeMs: reader.readInt32(),
     responses: reader.readArray((r, i) => {
       const errorCode = r.readInt16()
+      const errorMessage = r.readNullableString()
 
       if (errorCode !== 0) {
-        errors.push([`/responses/${i}`, errorCode])
+        errors.push([`/responses/${i}`, [errorCode, errorMessage]])
       }
 
       return {
         errorCode,
-        errorMessage: r.readNullableString(),
+        errorMessage,
         resourceType: r.readInt8(),
         resourceName: r.readString()
       }

src/apis/admin/alter-partition-reassignments-v0.ts

@@ -76,15 +76,16 @@ export function parseResponse (
 
   const throttleTimeMs = reader.readInt32()
   const errorCode = reader.readInt16()
+  const errorMessage = reader.readNullableString()
 
   if (errorCode !== 0) {
-    errors.push(['', errorCode])
+    errors.push(['', [errorCode, errorMessage ?? '']])
   }
 
   const response: AlterPartitionReassignmentsResponse = {
     throttleTimeMs,
     errorCode,
-    errorMessage: reader.readNullableString(),
+    errorMessage,
     responses: reader.readArray((r, i) => {
       return {
         name: r.readString(),
@@ -96,7 +97,7 @@ export function parseResponse (
           }
 
           if (partition.errorCode !== 0) {
-            errors.push([`responses/${i}/partitions/${j}`, partition.errorCode])
+            errors.push([`responses/${i}/partitions/${j}`, [partition.errorCode, partition.errorMessage]])
           }
 
           return partition

src/apis/admin/alter-partition-v3.ts

@@ -104,7 +104,7 @@ export function parseResponse (
   const errorCode = reader.readInt16()
 
   if (errorCode !== 0) {
-    errors.push(['/', errorCode])
+    errors.push(['/', [errorCode, null]])
   }
 
   const response: AlterPartitionResponse = {
@@ -125,7 +125,7 @@ export function parseResponse (
           }
 
           if (partition.errorCode !== 0) {
-            errors.push([`/topics/${i}/partitions/${j}`, partition.errorCode])
+            errors.push([`/topics/${i}/partitions/${j}`, [partition.errorCode, null]])
           }
 
           return partition

src/apis/admin/alter-replica-log-dirs-v2.ts

@@ -76,7 +76,7 @@ export function parseResponse (
           }
 
           if (partition.errorCode !== 0) {
-            errors.push([`/results/${i}/partitions/${j}`, partition.errorCode])
+            errors.push([`/results/${i}/partitions/${j}`, [partition.errorCode, null]])
           }
 
           return partition

src/apis/admin/alter-user-scram-credentials-v0.ts

@@ -87,7 +87,7 @@ export function parseResponse (
       }
 
       if (result.errorCode !== 0) {
-        errors.push([`/results/${i}`, result.errorCode])
+        errors.push([`/results/${i}`, [result.errorCode, result.errorMessage]])
       }
 
       return result

src/apis/admin/consumer-group-describe-v0.ts

@@ -101,14 +101,15 @@ export function parseResponse (
     throttleTimeMs: reader.readInt32(),
     groups: reader.readArray((r, i) => {
       const errorCode = r.readInt16()
+      const errorMessage = r.readNullableString()
 
       if (errorCode !== 0) {
-        errors.push([`/groups/${i}`, errorCode])
+        errors.push([`/groups/${i}`, [errorCode, errorMessage]])
       }
 
       return {
         errorCode,
-        errorMessage: r.readNullableString(),
+        errorMessage,
         groupId: r.readString(),
         groupState: r.readString(),
         groupEpoch: r.readInt32(),

src/apis/admin/create-acls-v3.ts

@@ -75,7 +75,7 @@ export function parseResponse (
       }
 
       if (result.errorCode !== 0) {
-        errors.push([`/results/${i}`, result.errorCode])
+        errors.push([`/results/${i}`, [result.errorCode, result.errorMessage]])
       }
 
       return result

src/apis/admin/create-delegation-token-v3.ts

@@ -83,7 +83,7 @@ export function parseResponse (
   }
 
   if (response.errorCode !== 0) {
-    throw new ResponseError(apiKey, apiVersion, { '': response.errorCode }, response)
+    throw new ResponseError(apiKey, apiVersion, { '/': [response.errorCode, null] }, response)
   }
 
   return response

src/apis/admin/create-partitions-v3.ts

@@ -79,7 +79,7 @@ export function parseResponse (
       }
 
       if (result.errorCode !== 0) {
-        errors.push([`/results/${i}`, result.errorCode])
+        errors.push([`/results/${i}`, [result.errorCode, result.errorMessage]])
       }
 
       return result