我正在用apache flink创建一个处理数百万条记录的流程来支持后勤数据管道，我正在从kinesis sources/sink迁移到Kafka sources/sink。
然而，在flink Jmeter 板中，作业指标没有被近乎实时地更新。你知道作业/版本可能出了什么问题吗？
顺便说一句，当作业关闭时，它可以显示所有指标...但不是近实时的...
作业非更新度量图片
我正在用apache flink创建一个处理数百万条记录的流程来支持后勤数据管道，我正在从kinesis sources/sink迁移到Kafka sources/sink。
然而，在flink Jmeter 板中，作业指标没有被近乎实时地更新。你知道作业/版本可能出了什么问题吗？
顺便说一句，当作业关闭时，它可以显示所有指标...但不是近实时的...
作业非更新度量图片
1条答案
按热度按时间ffx8fchx1#
在清除“Kafka-clients”库上的冲突依赖项后修复。
所以，在我的例子中，也使用一些avro和cloudevents库与更高的Kafka客户端版本。然后，只需要从这些库中排除Kafka客户端，并首选flink Kafka客户端版本。这就解决了这个问题。