fix deserialized error

apache · Jun 22, 2021 · 5c222bd · 5c222bd
1 parent 0a67b45
commit 5c222bd
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java
@@ -330,7 +330,10 @@ public String getReplicatedFrom() {
 
     @Override
     public long getPublishTime() {
-        return msgMetadata.getPublishTime();
+        if (msgMetadata.hasPublishTime()) {
+            return msgMetadata.getPublishTime();
+        }
+        return 0;
     }
 
     @Override