从confluent kafka中的genericrecord对象获取原始记录

7ajki6be  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(227)

我正在消费者中获取genericrecord类型行。然而,当我通过 genericRecord.TryGetValue(...) ,即使该字段不是由生产者发送的,也返回true。
我有这样的模式:

{
                  "name": "GROUP",
                  "type": [
                    "null",
                    "string"
                  ],
                  "default": null
                },
                {
                  "name": "NICKNAME",
                  "type": [
                    "null",
                    "string"
                  ],
                  "default": null
                },

现在制作人只发送记录中的昵称,我想看看用户到底发送了哪个字段。使用trygetvalue,我得到true,而“group”字段的值为null,我希望它应该返回false。
我也试过了 genericRecord.ToBsonDocument().Contains(fieldName) 但对于这两个字段,它都返回false,即使我有“group”和“nickname”字段。
有什么建议吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题