diff --git a/apps/emqx_bridge/src/emqx_bridge_api.erl b/apps/emqx_bridge/src/emqx_bridge_api.erl
index 8696aadaa..851089acb 100644
--- a/apps/emqx_bridge/src/emqx_bridge_api.erl
+++ b/apps/emqx_bridge/src/emqx_bridge_api.erl
@@ -504,7 +504,10 @@ do_probe(ConnType, Params) ->
     end.
 
 host_and_port(mqtt, #{<<"server">> := Server}) ->
-    Server;
+    case string:split(Server, ":") of
+        [Host, Port] -> {Host, list_to_integer(Port)};
+        _Other -> error(invalid_server, Server)
+    end;
 host_and_port(webhook, #{<<"url">> := Url}) ->
     {BaseUrl, _Path} = parse_url(Url),
     {ok, #{host := Host, port := Port}} = emqx_http_lib:uri_parse(BaseUrl),