kafka avro模式 - 1000郵件後出現500內部服務器錯誤

Question

我正在使用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); 
} 
} 

Answer 1

看起來像一個修復即將到來的https://github.com/confluentinc/kafka-rest-node/issues/21

同時，我們正在使用的模式ID生成消息