diff --git a/app/kafka/manager/model/model.scala b/app/kafka/manager/model/model.scala
index bf8e996bb..250373229 100644
--- a/app/kafka/manager/model/model.scala
+++ b/app/kafka/manager/model/model.scala
@@ -175,6 +175,7 @@ object ClusterConfig {
 
   def validateZkHosts(zkHosts: String): Unit = {
     require(zkHosts.length > 0, "cluster zk hosts is illegal, can't be empty!")
+    require(zkHosts.contains(":"), "cluster zk hosts is illegal, should contain colon!")
   }
 
   def apply(name: String