fix tests

chenhongSZ · Mar 21, 2024 · dc83971 · dc83971
1 parent 22807e1
commit dc83971
Showing 1 changed file with 3 additions and 2 deletions.
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
@@ -86,13 +86,14 @@ private List<String> consume(ChaosContainer<?> container, String url, String top
                     + "\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));
         }
         return received;
     }
-
 }