我正在使用flink读取kafka流，现在我想计算每秒事务数（tps）。我在flink中观察到了通过使用窗口概念来实现这一点的方法之一，但还不能得到它。有谁能帮我一下吗。提前谢谢你的帮助！！。
byqmnocz1#
有一个内置的度量报告numrecordsoutpersecond，您可以在kafka源操作符（或任何其他操作符）上观察到它。也许这就是你所需要的：有关学习如何使用flink窗口api的教程（和示例），请参阅文档中flink培训课程中的windows简介。
1条答案
按热度按时间byqmnocz1#
有一个内置的度量报告numrecordsoutpersecond，您可以在kafka源操作符（或任何其他操作符）上观察到它。也许这就是你所需要的：
有关学习如何使用flink窗口api的教程（和示例），请参阅文档中flink培训课程中的windows简介。