diff --git a/lib-ee/emqx_ee_connector/src/emqx_ee_connector_influxdb.erl b/lib-ee/emqx_ee_connector/src/emqx_ee_connector_influxdb.erl
index 2024ba8ce..3f86792ff 100644
--- a/lib-ee/emqx_ee_connector/src/emqx_ee_connector_influxdb.erl
+++ b/lib-ee/emqx_ee_connector/src/emqx_ee_connector_influxdb.erl
@@ -485,8 +485,12 @@ log_error_points(InstId, Errs) ->
 %% ===================================================================
 %% typereflt funcs
 
--spec to_server_raw(string()) ->
+-spec to_server_raw(string() | binary()) ->
     {string(), pos_integer()}.
+to_server_raw(<<"http://", Server/binary>>) ->
+    emqx_connector_schema_lib:parse_server(Server, ?INFLUXDB_HOST_OPTIONS);
+to_server_raw(<<"https://", Server/binary>>) ->
+    emqx_connector_schema_lib:parse_server(Server, ?INFLUXDB_HOST_OPTIONS);
 to_server_raw(Server) ->
     emqx_connector_schema_lib:parse_server(Server, ?INFLUXDB_HOST_OPTIONS).