(pulsar) branch master updated: [improve][cli] CmdConsume print publishTime And eventTime info. (#22308)

[aloyszhang]

This is an automated email from the ASF dual-hosted git repository.

aloyszhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 74585b5ae07 [improve][cli] CmdConsume print publishTime And eventTime 
info. (#22308)
74585b5ae07 is described below

commit 74585b5ae07a5ab10d85f9a8bc80e3093b7cff20
Author: atomchen <492672...@qq.com>
AuthorDate: Thu Mar 21 18:29:53 2024 +0800

    [improve][cli] CmdConsume print publishTime And eventTime info. (#22308)
    
    Co-authored-by: atomchchen <atomchc...@tencent.com>
---
 .../main/java/org/apache/pulsar/client/cli/AbstractCmdConsume.java | 3 +++
 .../org/apache/pulsar/tests/integration/cli/ClientToolTest.java    | 7 ++++---
 2 files changed, 7 insertions(+), 3 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
index a7932c732eb..658b34767b5 100644
--- 
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 @@ public abstract class AbstractCmdConsume extends 
AbstractCmd {
             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();
diff --git 
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/ClientToolTest.java
 
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/ClientToolTest.java
index 571948443b1..0d6b6f1abe4 100644
--- 
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/ClientToolTest.java
+++ 
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/ClientToolTest.java
@@ -86,13 +86,14 @@ public class ClientToolTest extends TopicMessagingBase {
                     + "\nError output:\n" + result.getStderr());
         }
         String output = result.getStdout();
-        Pattern message = Pattern.compile("----- got message 
-----\nkey:\\[null\\], properties:\\[\\], content:(.*)");
+        Pattern message = Pattern.compile(
+                "----- got message -----\npublishTime:\\[(.*)\\], 
eventTime:\\[(.*)\\], key:\\[null\\], "
+                        + "properties:\\[\\], content:(.*)");
         Matcher matcher = message.matcher(output);
         List<String> received = new ArrayList<>(MESSAGE_COUNT);
         while (matcher.find()) {
-            received.add(matcher.group(1));
+            received.add(matcher.group(3));
         }
         return received;
     }
-
 }