diff --git a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarConsumerOp.java b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarConsumerOp.java index 93766a33a..783a8b4c2 100644 --- a/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarConsumerOp.java +++ b/driver-pulsar/src/main/java/io/nosqlbench/driver/pulsar/ops/PulsarConsumerOp.java @@ -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); } }