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

Question

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

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

有人能帮我理解如何重用这个模式吗？

谢谢，Rajesh

"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);
 }
}

Answer 1

看起来很快就会有修复了，https://github.com/confluentinc/kafka-rest-node/issues/21

同时，我们使用模式Id来生成消息