如何在Flink?中获取Kafkasource的吞吐量

Question

我想知道kafkasource的吞吐量。换句话说，我想测量Flink读取数据的速度。我的想法是在源之后添加地图运算符，并在地图操作员中使用内置指标。这会增加开销吗？我希望在不增加大量开销的情况下获得这个指标。我应该怎么办？还是有一种方法可以在Kafka中获取此主题的输出吞吐量？或者我应该通过REST API获得Kafkasource的NumberSutpersecond？

Answer 1

看一下Kafka Manager，该管理器显示了许多与Kafka相关的指标。它是一种用于管理Kafka并充当实时仪表板的工具。您需要单独安装和配置。

这可用于检查弗林克消费者的消费率。

您还可以在源操作员上使用内置指标出版商，而无需仅用于此目的。