Pulsar: report latency in ns for Payload RRT

This commit is contained in:
Enrico Olivelli 2022-01-29 12:11:14 +01:00
parent 5a44b6d06f
commit 3b184a0c23

View File

@ -279,7 +279,9 @@ public class PulsarConsumerOp implements PulsarOp {
}
}
if (extractedSendTime != null) {
long delta = System.currentTimeMillis() - extractedSendTime;
// fallout expects latencies in "ns" and not in "ms"
long delta = TimeUnit.MILLISECONDS
.toNanos(System.currentTimeMillis() - extractedSendTime);
payloadRttHistogram.update(delta);
}
}