diff --git a/apps/emqx_bridge_hstreamdb/src/emqx_bridge_hstreamdb_connector.erl b/apps/emqx_bridge_hstreamdb/src/emqx_bridge_hstreamdb_connector.erl index 16092f262..1e2ebbfb1 100644 --- a/apps/emqx_bridge_hstreamdb/src/emqx_bridge_hstreamdb_connector.erl +++ b/apps/emqx_bridge_hstreamdb/src/emqx_bridge_hstreamdb_connector.erl @@ -119,10 +119,13 @@ roots() -> fields(config) -> [ - {url, mk(binary(), #{required => true, desc => ?DESC("url")})}, + {url, + mk(binary(), #{ + required => true, desc => ?DESC("url"), default => <<"http://127.0.0.1:6570">> + })}, {stream, mk(binary(), #{required => true, desc => ?DESC("stream_name")})}, {partition_key, mk(binary(), #{required => false, desc => ?DESC("partition_key")})}, - {pool_size, mk(pos_integer(), #{required => true, desc => ?DESC("pool_size")})}, + {pool_size, fun emqx_connector_schema_lib:pool_size/1}, {grpc_timeout, fun grpc_timeout/1} ] ++ emqx_connector_schema_lib:ssl_fields(). diff --git a/rel/i18n/emqx_bridge_hstreamdb_connector.hocon b/rel/i18n/emqx_bridge_hstreamdb_connector.hocon index c0faa794c..8f7ac2edb 100644 --- a/rel/i18n/emqx_bridge_hstreamdb_connector.hocon +++ b/rel/i18n/emqx_bridge_hstreamdb_connector.hocon @@ -19,31 +19,31 @@ name.label: """Connector Name""" url.desc: -"""HStreamDB Server URL""" +"""HStreamDB Server URL. Using gRPC http server address.""" url.label: """HStreamDB Server URL""" stream_name.desc: -"""HStreamDB Stream Name""" +"""HStreamDB Stream Name.""" stream_name.label: """HStreamDB Stream Name""" partition_key.desc: -"""HStreamDB Ordering Key""" +"""HStreamDB Partition Key. Placeholders supported.""" partition_key.label: -"""HStreamDB Ordering Key""" +"""HStreamDB Partition Key""" pool_size.desc: -"""HStreamDB Pool Size""" +"""HStreamDB Pool Size.""" pool_size.label: """HStreamDB Pool Size""" grpc_timeout.desc: -"""HStreamDB gRPC Timeout""" +"""HStreamDB gRPC Timeout.""" grpc_timeout.label: """HStreamDB gRPC Timeout"""