发送Kafka消息的更好方式:JsonNode或Map<String,UserModel>?

问题描述 投票:0回答:1

我是一个使用Spring Boot的Kafka新手,我们可以用Json String Streams、JsonNode Map、UserModel等方式发送Kafka消息。

我们可以用Json String Streams JsonNode Map来发送kafka消息。所以现在在我的项目中,我想把Map发送给我的一个消费者。

所以作为一个步骤,首先我们将地图转换为JsonNode,然后将发送JsonNode。在消费者那里,我们将这个JsonNode去掉,变成Map,然后使用。

我尝试发送地图,我可以通过kafka发送。在消费者那里,我得到的是Json String。

所以我的问题是,在我的需求中,哪种方式是最好的实现方式?

java json apache-kafka kafka-consumer-api
1个回答
1
投票

我的观点--------------。既不.

使用Avro(或Protobuf)模型类,明确定义你的类型和。模式注册表


换句话说,Kafka存储的是字节。你可以 挑选 任何 序列化格式你最好把它也压缩一下

© www.soinside.com 2019 - 2024. All rights reserved.