diff --git a/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/ops/OpTimeTrackKafkaConsumer.java b/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/ops/OpTimeTrackKafkaConsumer.java
index f68b5b040..9638ca855 100644
--- a/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/ops/OpTimeTrackKafkaConsumer.java
+++ b/adapter-kafka/src/main/java/io/nosqlbench/adapter/kafka/ops/OpTimeTrackKafkaConsumer.java
@@ -116,10 +116,11 @@ public class OpTimeTrackKafkaConsumer extends OpTimeTrackKafkaClient {
                 if (record != null) {
                     if (logger.isDebugEnabled()) {
                         logger.debug(
-                            "Receiving message is successful: [{}] - offset({}), cycle ({})",
+                            "Receiving message is successful: [{}] - offset({}), cycle ({}), e2e_latency_ms({})",
                             printRecvedMsg(record),
                             record.offset(),
-                            cycle);
+                            cycle,
+                            System.currentTimeMillis() - record.timestamp());
                     }
 
                     if (!autoCommitEnabled) {