diff --git a/services/replicator/inconn.go b/services/replicator/inconn.go
index f5374ef4..2131cdfa 100644
--- a/services/replicator/inconn.go
+++ b/services/replicator/inconn.go
@@ -175,7 +175,7 @@ func (conn *inConnection) writeMsgsStream() {
 
 				// Update per destination metrics after msg is sent to local store (call is OpenReplicationRemoteRead)
 				// so they're most accurate.
-				if conn.metricsScope == metrics.OpenReplicationRemoteReadScope {
+				if conn.metricsScope == metrics.OpenReplicationRemoteReadScope && msg.GetType() == store.ReadMessageContentType_MESSAGE {
 					conn.destM3Client.IncCounter(conn.perDestMetricsScope, metrics.ReplicatorInConnPerDestMsgWritten)
 					latency := time.Duration(time.Now().UnixNano() - msg.GetMessage().Message.GetEnqueueTimeUtc())
 					conn.destM3Client.RecordTimer(conn.perDestMetricsScope, metrics.ReplicatorInConnPerDestMsgLatency, latency)