java - 使用 KStreams 有状态或无状态转换查找最大值、最小值和平均值？

Question

我想知道我必须执行哪些有状态或无状态操作才能找到记录中字段年龄的最大值、最小值和平均值Kstream。

用户有两个字段int age String name. 关键是String name

---

KStream<String, user> stream = builder.stream("Topic1");

标签： javalambdastreamapache-kafkaapache-kafka-streams