From ec9f4c708c30566d8dc0ac2fd685f1609cff2048 Mon Sep 17 00:00:00 2001
From: mukesh-ctds <ext-mukesh.kumar@datastax.com>
Date: Wed, 12 Mar 2025 12:54:17 +0530
Subject: [PATCH] Fix issue with MessageDeduplication

---
 .../pulsar/broker/service/persistent/MessageDeduplication.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java
index bf482986ec980..1463ee83158f2 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java
@@ -372,7 +372,7 @@ private void setContextPropsIfRepl(PublishContext publishContext, ByteBuf header
             // Message is coming from replication, we need to use the replication's producer name, ledger id and entry
             // id for the purpose of deduplication.
             MessageMetadata md = Commands.peekMessageMetadata(headersAndPayload, "Check-Deduplicate", -1);
-            if (Markers.isReplicationMarker(md.getMarkerType())) {
+            if (md != null && md.hasMarkerType() && Markers.isReplicationMarker(md.getMarkerType())) {
                 publishContext.setProperty(MSG_PROP_IS_REPL_MARKER, "");
             }
             return;