KafkaIO()/Kafka Data Monitoring

[amir bahmanyari]

Hi Colleagues,Any suggestions on how to monitor the data rate coming to Beam 
app (KafkaIO()) running in a Flink cluster from Kafka?The Flink dashboard 
doesn't show any changes...its 0's all the time.. 
I thought there may be a utility/tool that I can intercept/monitor the rate at 
which Kafka sends to the Beam app in Flink cluster?
Thanks+regards.