; Hi David
>>
>> FlinkKafkaConsumer in itself is RichParallelSourceFunction, and you could
>> call function below to register your metrics group:
>>
>> getRuntimeContext().getMetricGroup().addGroup("MyMetrics").counter("myCounter")
>>
>>
>>
>>
;MyMetrics").counter("myCounter")
Best
Yun Tang
*From:* David Magalhães mailto:speeddra...@gmail.com>>
*Sent:* Tuesday, January 21, 2020 3:45
*To:* user mailto:user@flink.apache.org>>
*Subject:* Cust
---
> *From:* David Magalhães
> *Sent:* Tuesday, January 21, 2020 3:45
> *To:* user
> *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 deserializ
avid Magalhães
Sent: Tuesday, January 21, 2020 3:45
To: user
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
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,
