Как читать специфичные данные GenericRecord в слитной кафке C # - PullRequest
Новая
       73

Как читать специфичные данные GenericRecord в слитной кафке C #

0 голосов
/ 23 апреля 2019

Это мой простой фрагмент кода, в котором я пытаюсь прочитать потребителя общей формы записи Avro: 

using (var schemaRegistry = new CachedSchemaRegistryClient(new SchemaRegistryConfig { SchemaRegistryUrl = schemaRegistryUrl }))
  using (var consumer = new 
        ConsumerBuilder<string, GenericRecord>(new ConsumerConfig { BootstrapServers = bootstrapServers, GroupId = groupName })
                        .SetKeyDeserializer(new AsyncAvroDeserializer<string>(schemaRegistry).AsSyncOverAsync())
                        .SetValueDeserializer(new AsyncAvroDeserializer<GenericRecord>(schemaRegistry).AsSyncOverAsync())
                        .SetErrorHandler((_, e) => Console.WriteLine($"Error: {e.Reason}"))
                        .Build())
                {
      consumer.Subscribe(topicName);

      try
       {
           while (true)
             {
                try
                 {
                    var consumeResult = consumer.Consume();
                    Console.WriteLine($"Key: {consumeResult.Message.Key}\nValue: {consumeResult.Value}");
                    Console.WriteLine(consumeResult.Value.Schema);
                            Console.WriteLine(consumeResult.Value.Schema["favorite_number"]);

                  }
                 catch (ConsumeException e)
                   {
                       Console.WriteLine($"Consume error: {e.Error.Reason}");
                            }
                        }
                    }
                    catch (OperationCanceledException)
                    {
                        // commit final offsets and leave the group.
                        consumer.Close();
                    }
                }

Как вы можете видеть, я могу войти в схему, но не знаю, как получить ее значение данных.

 Console.WriteLine(consumeResult.Value.Schema);

 Console.WriteLine(consumeResult.Value.Schema["favorite_number"]);

Пока схема и данные в этом объекте похожи на это consumeResult.Value:

{Schema: {"type": "record", "name": "User","пространство имен": "Confluent.Kafka.Examples.AvroSpecific", "полей": [{ "имя": "имя", "типа": "строка"}, { "имя": "favorite_number", "типа":["int", "null"]}, {"name": "favour_color", "type": ["string", "null"]}]}, contents : {name: sfs,Код_любленного: 41, Цвет_любленного: синий,}}

Я хочу прочитать данные содержимого.

1 Ответ

0 голосов
/ 23 апреля 2019

content недоступен

Не думаю, что Value.contents - это то, что вы хотите.В частности, потому что это свойство private, как вы упомянули

Получатель определен как словарь - Исходный код

Попробуйте consumeResult.Value["favorite_number"]

Когда вы делаете consumeResult.Value.Schema["favorite_number"], вы получаете объект Field в схеме, а не значение поля во внешней записи.- Исходный код

...