Hi,
Thanks for your reply. port means akka tcp port. Because I want to unique
identify a taskmanager. container_id is an other choice.
Kafka metric reporter implement kafka interface, that is not a flink
MetricReporter. So i can’t get flink runtime info directly.
> 在 2018年9月13日,下午4:25,Dawid W
Hi,
For the hostname, by default identifier for metrics scoped to
taskmanager contain its hostname. You can read more about metrics scope
here[1].
What do you mean by port? Which port would you like to report?
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.6/monitoring/metrics.ht
Hello community,
Is there a way to get taskmanager hostname and port on runtime?
I’d like to implement a kafka metric reporter, reporter should be able
to report the taskmanager hostname and port to monitoring system.
Thanks.