C# и AVRO: ожидание данных с реестрами схемы схемы. Магический байт был 79, ожидая 0 ⇐ C#

[Anonymous]

Я пытаюсь покинуть данные AVRO из Кафки, используя эту конструкцию. Получение данных KAFKA работает нормально. Спецификации в «kafka_schema.avro» подходят для данных Kafka. Но: независимо от того, что я попробую, я Geht исключение "Local: value deserialization error" за пределами внутреннего исключения «ожидая данных с кадром реестра схемы схемы. Magic Byte был 79, ожидая 0» < /p>

Код: Выделить всё

using (var schemaRegistry = new CachedSchemaRegistryClient(new SchemaRegistryConfig { Url = "kafka_schema.avro" })) {
using (var builder = new ConsumerBuilder(GetConf())
.SetValueDeserializer(new AvroDeserializer(schemaRegistry).AsSyncOverAsync())
.Build()) {
builder.Subscribe(GetCredential(TOPIC));
try {
while (true) {
try {
/* THIS WORKS */
string id = builder.MemberId;
/* THIS FAILS */
var consumer = builder.Consume(cancellationToken);
Console.WriteLine($"{consumer.Message.Value}");
}
catch (ConsumeException e) {
Console.WriteLine($"Consume error: {e.InnerException}");
return Task.CompletedTask;
}
}
}
catch (OperationCanceledException) {
// commit final offsets and leave the group.
builder.Close();
}
}
}

Есть идеи, что не так?

Подробнее здесь: https://stackoverflow.com/questions/794 ... ng-magic-b