KafkaStreams Scala 在 2 个字段上分组以获得不同的计数

Question

我的 Kafka 主题中有以下键值对数据

0 -> {"UserId":"123","DateAndTime":"2020-06-10T10:30:03.000Z"}
0 -> {"UserId":"123","DateAndTime":"2020-05-10T10:30:03.000Z"}
1 -> {"UserId":"234","DateAndTime":"2020-06-10T10:30:03.000Z"}
1 -> {"UserId":"235","DateAndTime":"2020-06-10T10:33:03.000Z"}

如何使用 Scala 中的 Kafka Streams 获取 DateAndTime 在今天日期间隔内的每个键的用户数？

输出应该是这样的

Key -> Count of Users
0 -> 1
1 -> 2

Answer 1

您应该查看文档和示例：

• https://docs.confluent.io/current/streams/developer-guide/dsl-api.html#
• https://github.com/confluentinc/kafka-streams-examples/blob/5.4.1-post/src/main/scala/io/confluent/examples/streams/WordCountScalaExample.scala

你基本上申请了KStream#groupByKey()#windowedBy(TimeWindow.of(Duration.ofDay(1)))#count()