Confluent_Schema_Registry - Error, status 400

[Lucky38i]

Hi all,

We've recently been trying to use this library in our AWS Node Lambdas to register a schema and then encode with it.

const schema = await readAVSCAsync(getSchemaFromKey(s3ObjectKey))
const {id} = await registry.register({type: SchemaType.AVRO, schema})

However I keep running into a recurring error during the register method call with a status 400. The call being made by the library is perfectly valid so it's a bit perplexing why it would be returning 400 and there's no other logs for me to go off of.

{
    "errorType": "ResponseError",
    "errorMessage": "Confluent_Schema_Registry - Error, status 400",
    "name": "ResponseError",
    "status": 400,
    "unauthorized": false,
    "url": "get https://<confluent-url>/config/<subject>",
    "stack": [
        "ResponseError: Confluent_Schema_Registry - Error, status 400",
        "    at /var/task/index.js:2206:102",
        "    at process.processTicksAndRejections (node:internal/process/task_queues:95:5)"
    ]
}

I've tried making the exact same call via bruno and I get a 404 as expected as compatability has not been configured for the subject.

Any ideas?

[simonpetty]

FWIW i've had this when using basic auth encoded in the host URI and if i swap to using auth to pass them in, it works. Apparently though some are successfully using the former, so my current guess is certain usernames/passwords it doesn't like (tried encodeURI too).

[jeffkni]

Thanks for the hint @simonpetty
We see this issue when using Deno.

This code normally works:

import { SchemaRegistry } from '@kafkajs/confluent-schema-registry';

const host = 'https://my-url';
const username = 'my-username';
const password = 'my-password';

const registry = new SchemaRegistry(
      {
        host,
        auth: {
          password,
          username
        }
      }
    );
registry.getSchema(1234).then( x => console.log(JSON.stringify(x))).catch(e => console.error("OH NO",e));

but in Deno we get

Confluent_Schema_Registry - Error, status 400: connection error

changing to sending headers in middleware fixed it:

const registry = new SchemaRegistry(
  {
    host,
    middlewares: [
      () => ({
        prepareRequest: async (next, abort) => {
          const request = await next();
          return request.enhance({
            headers: {
              ...request.headers(),
               'Authorization': 'Basic ' + btoa(`${username}:${password}`),
            },
          });
        },
      }),
    ],
  }
);