diff --git a/functions/onprem/orborus/orborus.go b/functions/onprem/orborus/orborus.go
index dc9e554c..cdface09 100755
--- a/functions/onprem/orborus/orborus.go
+++ b/functions/onprem/orborus/orborus.go
@@ -2286,8 +2286,9 @@ func createPipeline(command, identifier string) (string, error) {
 		log.Printf("[INFO] an existing pipeline found with ID: %s. it will be deleted", pipelineId)
 		toBeDeleted = true
 	}
+    if strings.Contains(command, "shuffler.io") {
 
-	if strings.Contains(command, "kafka") {
+	} else {
 		var scheme string
 		if strings.Contains(command, "http://") {
 			scheme = "http://"