我是一个使用Spring Boot的Kafka新手,我们可以用Json String Streams、JsonNode Map、UserModel等方式发送Kafka消息。
我们可以用Json String Streams JsonNode Map来发送kafka消息。所以现在在我的项目中,我想把Map发送给我的一个消费者。
所以作为一个步骤,首先我们将地图转换为JsonNode,然后将发送JsonNode。在消费者那里,我们将这个JsonNode去掉,变成Map,然后使用。
我尝试发送地图,我可以通过kafka发送。在消费者那里,我得到的是Json String。
所以我的问题是,在我的需求中,哪种方式是最好的实现方式?
我的观点--------------。既不.
使用Avro(或Protobuf)模型类,明确定义你的类型和。模式注册表
换句话说,Kafka存储的是字节。你可以 挑选 任何 序列化格式你最好把它也压缩一下