如何在汇流kafka C#中读取GenericRecord特定数据

Question

这是我的一个简单代码片段，它试图从使用者读取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”,“namespace”：“confluent.kafka.example.avrospecific”,“fields”：[{“name”：“name”,“type”：“string”},{“name”：“favorite_number”,“type”：[“int”,“null”]},{“name”：“favorite_color”,“type”：[“string”,“null”]}]},内容：{name:sfs,favorite_number:41,

我要读取内容数据。

Answer 1

内容不可访问

我认为value.contents不是您想要的。特别是因为该属性是private，正如您提到的

getter的定义类似于字典-源代码

尝试consumeresult.value[“favorite_number”]

当您执行consumeresult.value.schema[“favorite_number”]时，您得到的是架构中的field对象，而不是外部记录中字段的值。-源代码