小编Meg*_*ind的帖子

如何使用KeyValueMapper将输入的KStream <String,String>映射到<String,CarClass>?

接收我只是想在CarClass上映射并想要创建新流的Json数据,但是map方法不允许我在自定义数据类型上进行映射。KStream类型的map(KeyValueMapper>)方法不适用于参数(新的KeyValueMapper>(){})?

apache-kafka apache-kafka-streams

1
推荐指数
1
解决办法
2244
查看次数

标签 统计

apache-kafka ×1

apache-kafka-streams ×1