gianm commented on issue #6587: emit maxLag/avgLag in KafkaSupervisor URL: https://github.com/apache/incubator-druid/pull/6587#issuecomment-438458548 How about adding a metric `ingest/kafka/partitionLag` with a dimension "partition" on it? Then you could take the average or max of those to get the average/max per-partition lag. But you could also look at the lag for each individual partition, which would be useful too. Maybe include the task ID as a dimension too?
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
