CmdConsume print publishTime And eventTime info.

chenhongSZ · Mar 20, 2024 · 22807e1 · 22807e1
1 parent 2803ba2
commit 22807e1
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/AbstractCmdConsume.java b/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/AbstractCmdConsume.java
@@ -108,6 +108,9 @@ protected String interpretMessage(Message<?> message, boolean displayHex) throws
             data = value.toString();
         }
 
+        sb.append("publishTime:[").append(message.getPublishTime()).append("], ");
+        sb.append("eventTime:[").append(message.getEventTime()).append("], ");
+
         String key = null;
         if (message.hasKey()) {
             key = message.getKey();