如何使用Kafka Confluent C#客户端发送原始Json?

问题描述

我有一个消费者应用程序,它期望JSON像这样:{"timestamp":1554138000,"level":"first","message":"abc"}。但是Confluent Message对象似乎是一个键值对字符串。我假设,消息KV对在内部序列化为json。但是,如何确保它不对时间戳记值加双引号?有没有办法将原始JSON作为消息传递?

解决方法

通过传递键的空字符串和值中的Json字符串,我能够生成消费者应用程序期望的Json