diff --git a/base/dcp_common.go b/base/dcp_common.go
index 47da59fba2..fe30af0f00 100644
--- a/base/dcp_common.go
+++ b/base/dcp_common.go
@@ -298,7 +298,7 @@ func GenerateDcpStreamName(feedID string) (string, error) {
 	commitTruncated := StringPrefix(GitCommit, 7)
 
 	return fmt.Sprintf(
-		"%v-v-%v-commit-%v-uuid-%v",
+		"sg:%v-v-%v-commit-%v-uuid-%v",
 		feedID,
 		ProductAPIVersion,
 		commitTruncated,