将 KStream<String, Map<String, Long>> 写入 Kafka 主题
Writing KStream<String, Map<String, Long>> to a Kafka Topic
我正在阅读 Kafka 中的一个主题并使用流应用程序将更改应用于我的数据。
我终于有一个看起来像这样的流 KStream<String, Map<String, Long>>。键 (String) 是一个散列，值是一个 Map，其中还包含一个键 (String)，它只是一个词干，值 (Long) 是一个计数。
如果有人能指出一种将此写回 Kafka 主题的好方法，那就太好了。我知道我云将 Map 转换为专有的 String 表示形式。但我认为这个问题有更优雅的解决方案，例如使用 Serdes 和 apache avro?
非常感谢
爱德华
您可以使用 Avro 或任何二进制格式
Map<String,?> 也由 JSON 对象表示，它不需要是专有的。 Kafka 自带 Jackson，所以定义一个 ObjectMapper 并将 Map 写入一个 JSONObject 实例
我正在阅读 Kafka 中的一个主题并使用流应用程序将更改应用于我的数据。
我终于有一个看起来像这样的流 KStream<String, Map<String, Long>>。键 (String) 是一个散列，值是一个 Map，其中还包含一个键 (String)，它只是一个词干，值 (Long) 是一个计数。
如果有人能指出一种将此写回 Kafka 主题的好方法，那就太好了。我知道我云将 Map 转换为专有的 String 表示形式。但我认为这个问题有更优雅的解决方案，例如使用 Serdes 和 apache avro?
非常感谢 爱德华
您可以使用 Avro 或任何二进制格式
Map<String,?> 也由 JSON 对象表示，它不需要是专有的。 Kafka 自带 Jackson，所以定义一个 ObjectMapper 并将 Map 写入一个 JSONObject 实例