从价值中创建计数金额的Kafka流

Question

我产生的数据如下：

{"name":"John","amount":46,"time":"2021-11-05T07:53:32.005751Z"}
{"name":"Mike","amount":46,"time":"2021-11-05T07:53:32.005751Z"}
{"name":"Lilu","amount":50,"time":"2021-11-05T07:53:32.005751Z"}

我需要使用Apache Kafka流的“金额”字段计数。

{"46": 2}
{"50": 1}

{"key":46, "count": 2}
{"key":50, "count": 1}

Answer 1

欢迎使用堆栈溢出！你好像是在找人为你写一些代码。堆栈溢出是一个问答站点，而不是代码编写服务。请看这里学习如何写出有效的问题。

您可以根据您的用例修改这个正式的合流示例。这个例子和你问的很相似。

为了进一步解释这一点，您需要创建一个流应用程序，在该应用程序中将主题中的数据读取到kstream中。您没有提供有关您的钥匙的信息。在合流示例中，使用map()方法显式地重新分区记录，为每个记录创建一个新的keyvalue实例（您可以使用amount作为键）。然后事件按键分组并计数。