kafka avro 模式 - 1000 条消息后出现 500 内部服务器错误答案

【问题标题】：kafka avro schema - 500 internal server error after 1000 messageskafka avro 模式 - 1000 条消息后出现 500 内部服务器错误
【发布时间】：2016-09-30 02:51:55
【问题描述】：

我正在使用 confluent 0.9 REST 代理和模式注册表在主题中生成 avro 消息。我正在使用“kafka-rest”节点模块。在 1000 条消息之后，它开始给出 500 内部服务器错误。在阅读了一些帖子后，我了解到此错误与可以为主题注册的主题的最大数量设置有关，并且重用架构是它的解决方案。

kafka-rest 文档说模式重用是透明地完成的。下面是我用来测试的示例代码。我仍然遇到同样的错误。

有人可以帮助我了解如何重用架构吗？

谢谢，拉杰什

"use strict";
var async = require('async');
var kafkaRest = require('kafka-rest');
var topicName = "avro-test";

var valueSchema = new kafkaRest.AvroSchema({
    "name": "UserInfo",
    "type": "record",
    "fields": [
        { "name": "id", "type": "int" },
        { "name": "name", "type": "string" }]
});


var kafka = new kafkaRest({"url": "http://localhost:8082"});
var target = kafka.topic(topicName);

// Avro key and value schema.
for(var i = 0; i <= 1005; i++) {
 var line = {'id': 1, 'name': 'Bob '};
 target.produce(valueSchema, line, handleResponse);

}
function handleResponse( err, res) {
 if (err) {
      console.log("Error producing messages " + err);
 }
}

【问题讨论】：

标签： kafka-producer-api

【解决方案1】：

看起来修复即将推出https://github.com/confluentinc/kafka-rest-node/issues/21

同时，我们正在使用模式 ID 来生成消息

【讨论】：