Deserialize Kafka-Avro-Message, полученный от AWS Lambda Trigger ⇐ C#

[Anonymous]

Мы создали триггер Kafka Lambda в AWS, чтобы потреблять из API Kafka Read. Соединение было успешным, и я могу получить объекты JSON в моей функции C# Lambda. Тем не менее, объекты JSON содержат свойство значения с сериализованными данными, и я изо всех сил пытаюсь покинуть его, используя нашу схему AVRO. Я использую пакеты Nugget Confluent.kafka и Confluent.schemaregistry.serdes.
Это моя попытка: < /p>

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

var value = myRecord.GetProperty("value").GetBytesFromBase64();

var schemaRegistryConfig = new SchemaRegistryConfig
{
Url = "mySchemaRegistry"

};

using var schemaRegistry = new CachedSchemaRegistryClient(schemaRegistryConfig);

var deserializer = new AvroDeserializer(schemaRegistry);
try
{
var result = deserializer.DeserializeAsync(value, false, SerializationContext.Empty).Result;
return result;
}
catch(Exception ex)
{
return null;
}
< /code>
В настоящее время deserializeasync бросает следующее исключение: < /p>
AvroDeserializer only accepts type parameters of int, bool, double, string, float, long, byte[], instances of ISpecificRecord and subclasses of SpecificFixed.

У кого -то есть опыт с аналогичной настройкой и может направить меня, как это может работать?>

Подробнее здесь: https://stackoverflow.com/questions/775 ... da-trigger