Hi David
FlinkKafkaConsumer in itself is RichParallelSourceFunction, and you could call
function below to register your metrics group:
getRuntimeContext().getMetricGroup().addGroup("MyMetrics").counter("myCounter")
Best
Yun Tang
________________________________
From: David Magalhães <[email protected]>
Sent: Tuesday, January 21, 2020 3:45
To: user <[email protected]>
Subject: Custom Metrics outside RichFunctions
Hi, I want to create a custom metric that shows the number of message that
couldn't be deserialized using a custom deserializer inside FlinkKafkaConsumer.
Looking into Metrics page (
https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/metrics.html
) that doesn't seem to be possible, because it it's a RichFunction.
Anyone know another way to achieve this ?
Thanks,
David
