使用Kafka schema

Kafka schema"/>

使用Kafka schema

我正在尝试使用schema API创建新的kafka-schema-registery。下面是实现：

        let value = JSON.stringify(avroSchema);

        let type= {"schema" : value}; 

         fetch(`${process.env.SCHEMA_REGISTRY_URL}/subjects/${topic}/versions`,
                { 
                  body : type,  
                  method : 'POST', 
                  headers :{ 'Content-Type': 'application/vnd.schemaregistry.v1+json,
                                              application/vnd.schemaregistry+json, application/json',
                             'Accept' : 'application/vnd.schemaregistry.v1+json,
                                         application/vnd.schemaregistry+json, application/json'            
                }
                })
            .then(res=>res.json())
            .then((result)=>{
                console.log('result is ', result);   
                 resolve(result);    
             })
            .catch((err)=>{
                console.log('err',err);
                reject(err);
            })

avroSchema的外观如下：

const avroSchema = {
      "type": "record",
      "name": "test",
      "fields" : [
            {"name": "field", "type": "long"},
    ]
  };

当我执行此代码时，我得到的是500 - Internal server error。

有人可以帮助我了解我要去哪里错吗？

服务器上存在错误，您的代码看起来还不错，但我建议您使用NPM软件包，而不是重新发明轮子-https://www.npmjs/package/avro-schema-registry