node.js - ResponseError：Confluent_Schema_Registry - 错误，状态 400

Question

我在 Nodejs 中使用 kafkajs 和 confluent-schema-registry。我可以记录 message.value (avro)，但在尝试解码时出错。它说： ResponseError: Confluent_Schema_Registry - 错误，状态 400

const payload = await registry.decode(message.value).catch(error => {
      console.log('error consuming payload', error);
});

Answer 1

如果您的 avro 架构 URL 在 https 上，则尝试在初始化 SchemaRegistry 期间指定代理。

const registry = new SchemaRegistry({
  host: 'Your host on https',
  // if you have auth for schema url
  auth: {
    username: 'username for schema url',
    password: 'password for schema url'
  },
  // specifying below agent explicitly helped us
  agent: new https.Agent({
    rejectUnauthorized: false
  })
})