diff --git a/fdbserver/ApplyMetadataMutation.cpp b/fdbserver/ApplyMetadataMutation.cpp
index 53d754ec6e..1bd7a02331 100644
--- a/fdbserver/ApplyMetadataMutation.cpp
+++ b/fdbserver/ApplyMetadataMutation.cpp
@@ -357,6 +357,7 @@ private:
 				}
 				toCommit->addTags(allSources);
 			}
+			TraceEvent(SevDebug, "SendingPrivatized_ChangeFeed", dbgid).detail("M", privatized);
 			toCommit->writeTypedMessage(privatized);
 		}
 	}
diff --git a/fdbserver/ApplyMetadataMutation.h b/fdbserver/ApplyMetadataMutation.h
index 90c03ede77..d4e47e0946 100644
--- a/fdbserver/ApplyMetadataMutation.h
+++ b/fdbserver/ApplyMetadataMutation.h
@@ -72,8 +72,9 @@ inline bool isMetadataMutation(MutationRef const& m) {
 	// FIXME: This is conservative - not everything in system keyspace is necessarily processed by
 	// applyMetadataMutations
 	if (m.type == MutationRef::SetValue) {
-		return m.param1.size() && m.param1[0] == systemKeys.begin[0] &&
-		       !m.param1.startsWith(nonMetadataSystemKeys.begin);
+		return (m.param1.size() && m.param1[0] == systemKeys.begin[0] &&
+		        !m.param1.startsWith(nonMetadataSystemKeys.begin)) ||
+		       m.param1.startsWith(changeFeedPrefix);
 	} else if (m.type == MutationRef::ClearRange) {
 		return m.param2.size() > 1 && m.param2[0] == systemKeys.begin[0] &&
 		       !nonMetadataSystemKeys.contains(KeyRangeRef(m.param1, m.param2));