java - 编写 KStream> 到 Kafka 主题

Question

我正在阅读 Kafka 中的主题并使用流应用程序将更改应用于我的数据。

最后我有一个看起来像这样的流KStream<String, Map<String, Long>>。键（String）是一个散列，值是一个 Map，其中还包含一个键（String），它只是一个词干，值（Long）是一个计数。

如果有人能指出我将其写回 Kafka 主题的好方法，那就太好了。我知道我将 Map 转换为专有的字符串表示形式。但我认为这个问题有更优雅的解决方案，例如使用Serdes和 apache avro？

非常感谢爱德华

标签： javaapache-kafkajava-8apache-kafka-streams

Answer 1

您可以使用 Avro 或任何二进制格式

AMap<String,?>也由一个 JSON 对象表示，它不需要是专有的。Kafka自带Jackson，所以定义一个ObjectMapper，将Map写入一个JSONObject实例