Add metrics about aiokafka HOT 4 OPEN

Any progress? Just noticed the consumer does not have the method .metrics()

from aiokafka.

Metrics are still not even documented in kafka-python. I think we should wait until it becomes a stable API there before adding those...
For now I'll remove those from 0.2.0 milestone

from aiokafka.

It's not something too complicated, but requires some time. Basically we need to take the metrics aggregators present in kafka-python and call sensors for respectful events. Like self._sensors.records_fetch_lag.record(highwater - last_offset) after each fetch to record lag samples.

from aiokafka.

Any updates on this? Having producer/consumers metrics for aiokafka seems like a super useful thing to have for debugging client side issues or investigating client vs server problems.

from aiokafka.