Ich benutze confluent 0.9 Rest Proxy und Schema-Registrierung, Avro Nachrichten in einem Thema zu produzieren. Ich verwende "kafka-rest" Knotenmodul. Nach 1000 Nachrichten gibt es 500 interne Serverfehler. Nach dem Lesen einiger Posts verstehe ich, dass dieser Fehler mit einer Einstellung für die maximale Anzahl von Subjekten zusammenhängt, die für ein Thema registriert werden können, und die Wiederverwendung des Schemas ist die Lösung dafür.kafka avro schema - 500 interner Server Fehler nach 1000 Nachrichten
Die kafka-Rest-Dokumentation besagt, dass die Wiederverwendung des Schemas transparent erfolgt. Unten ist der Beispielcode, den ich zum Testen verwendet habe. Ich bekomme immer noch den gleichen Fehler.
Könnte jemand mir helfen zu verstehen, wie ich das Schema wiederverwenden kann?
Danke, 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);
}
}