java - 发送 kafka 消息的更好方法：JsonNode 或 Map?

Question

我是使用 Spring Boot 的 Kafka 新手。

我们可以在 Json / String / Streams / JsonNode / Map 中发送 kafka 消息。所以现在在我的项目中，我想将 Map 发送给我的一位消费者。

因此，作为一个步骤，我们首先将 map 转换为 JsonNode，然后发送 JsonNode。在消费者端，我们将把这个 JsonNode 反序列化为 map，然后使用。

我试图发送地图，我可以通过 kafka 发送。当在消费者时，我得到 Json String。

所以我的问题是在我的要求中实现的最佳方式是什么？

标签： javajsonapache-kafkakafka-consumer-api

Answer 1

我的意见 -两者都不是。

使用明确定义您的类型和模式注册表的Avro（或 Protobuf）模型类

---

换句话说，Kafka 存储字节。您可以选择任何序列化格式，最好也压缩它