Hi,

I'd like to monitor consumer's lag.
Found this tool https://github.com/linkedin/Burrow.
But now realized that Samza is using it's own checkpointing mechanism.

So question is what's the best way to monitor whether and how much the
consumer is lagging?

On a related subject, I'd also like to monitor throughput per topic in
terms of messages per second and bytes per second. Should I query brokers
periodically, or maybe there is a better way?

Thanks,
Michael

Reply via email to