feat: generate a minimized emqx.conf

apps/emqx/src/emqx_config.erl

@@ -85,6 +85,7 @@
 ]).
 
 -include("logger.hrl").
+-include_lib("hocon/include/hoconsc.hrl").
 
 -define(CONF, conf).
 -define(RAW_CONF, raw_conf).
@@ -320,14 +321,31 @@ init_load(SchemaMod, RawConf) when is_map(RawConf) ->
     LocalOverrides = read_override_conf(#{override_to => local}),
     Overrides = hocon:deep_merge(ClusterOverrides, LocalOverrides),
     RawConfWithOverrides = hocon:deep_merge(RawConfWithEnvs, Overrides),
-    %% check configs against the schema
-    {_AppEnvs, CheckedConf} =
-        check_config(SchemaMod, RawConfWithOverrides, #{}),
     RootNames = get_root_names(),
-    ok = save_to_config_map(
-        maps:with(get_atom_root_names(), CheckedConf),
-        maps:with(RootNames, RawConfWithOverrides)
-    ).
+    RawConfAll = raw_conf_with_default(SchemaMod, RootNames, RawConfWithOverrides),
+    %% check configs against the schema
+    {_AppEnvs, CheckedConf} = check_config(SchemaMod, RawConfAll, #{}),
+    ok = save_to_config_map(CheckedConf, RawConfAll).
+
+%% keep the raw and non-raw conf has the same keys to make update raw conf easier.
+raw_conf_with_default(SchemaMod, RootNames, RawConf) ->
+    Fun = fun(Name, Acc) ->
+        case maps:is_key(Name, RawConf) of
+            true ->
+                Acc;
+            false ->
+                {_, {_, Schema}} = lists:keyfind(Name, 1, hocon_schema:roots(SchemaMod)),
+                Default =
+                    case hocon_schema:field_schema(Schema, type) of
+                        ?ARRAY(_) -> [];
+                        ?LAZY(?ARRAY(_)) -> [];
+                        _ -> #{}
+                    end,
+                Acc#{Name => Default}
+        end
+    end,
+    RawDefault = lists:foldl(Fun, #{}, RootNames),
+    maps:merge(RawConf, fill_defaults(SchemaMod, RawDefault, #{})).
 
 parse_hocon(Conf) ->
     IncDirs = include_dirs(),
@@ -466,9 +484,6 @@ get_schema_mod(RootName) ->
 get_root_names() ->
     maps:get(names, persistent_term:get(?PERSIS_SCHEMA_MODS, #{names => []})).
 
-get_atom_root_names() ->
-    [atom(N) || N <- get_root_names()].
-
 -spec save_configs(app_envs(), config(), raw_config(), raw_config(), update_opts()) ->
     ok | {error, term()}.
 save_configs(_AppEnvs, Conf, RawConf, OverrideConf, Opts) ->

apps/emqx_authn/etc/emqx_authn.conf

@@ -1 +1 @@
-authentication: []
+

apps/emqx_authz/etc/emqx_authz.conf

@@ -1,67 +1,15 @@
 authorization {
-    sources = [
-       # {
-       #      type: http
-       #      url: "https://emqx.com"
-       #      headers: {
-       #          Accept: "application/json"
-       #          Content-Type: "application/json"
-       #      }
-       # },
-       # {
-       #     type: mysql
-       #     server: "127.0.0.1:3306"
-       #     database: mqtt
-       #     pool_size: 1
-       #     username: root
-       #     password: public
-       #     auto_reconnect: true
-       #     ssl: {
-       #       enable: true
-       #       cacertfile:  "{{ platform_etc_dir }}/certs/cacert.pem"
-       #       certfile: "{{ platform_etc_dir }}/certs/client-cert.pem"
-       #       keyfile: "{{ platform_etc_dir }}/certs/client-key.pem"
-       #     }
-       #     query: "select ipaddress, username, clientid, action, permission, topic from mqtt_authz where ipaddr = ${peerhost} or username = ${username} or clientid = ${clientid}"
-       # },
-       # {
-       #     type: postgresql
-       #     server: "127.0.0.1:5432"
-       #     database: mqtt
-       #     pool_size: 1
-       #     username: root
-       #     password: public
-       #     auto_reconnect: true
-       #     ssl: {enable: false}
-       #     query: "select ipaddress, username, clientid, action, permission, topic from mqtt_authz where ipaddr = ${peerhost} or username = ${username} or username = '$all' or clientid = ${clientid}"
-       # },
-       # {
-       #     type: redis
-       #     server: "127.0.0.1:6379"
-       #     database: 0
-       #     pool_size: 1
-       #     password: public
-       #     auto_reconnect: true
-       #     ssl: {enable: false}
-       #     cmd: "HGETALL mqtt_authz:${username}"
-       # },
-       # {
-       #     type: mongodb
-       #     mongo_type: single
-       #     server: "127.0.0.1:27017"
-       #     pool_size: 1
-       #     database: mqtt
-       #     ssl: {enable: false}
-       #     collection: mqtt_authz
-       #     filter: { "$or": [ { "username": "${username}" }, { "clientid": "${clientid}" } ] }
-       # },
-       {
-            type: built_in_database
-       },
-       {
-            type: file
-            # file is loaded into cache
-            path: "{{ platform_etc_dir }}/acl.conf"
-       }
-    ]
+  cache: {
+    enable: true
+    max_size: 32
+    ttl: "60s"
+  }
+  deny_action: ignore
+  no_match: allow
+  sources: [
+    {
+      type: file
+      path: "{{ platform_etc_dir }}/acl.conf"
+    }
+  ]
 }

apps/emqx_auto_subscribe/etc/emqx_auto_subscribe.conf

@@ -1,45 +0,0 @@
-
-## When the device logs in successfully,
-## the auto-subscribe will complete the subscription for the device
-## according to the preset topics list.
-## Placeholders are supported.
-##
-## - ${clientid}
-## - ${username}
-## - ${host}
-## - ${port}
-##
-## Subscription options can be set at the same time.
-## Please refer to the official MQTT definition for these configuration items.
-## - qos
-## - rh
-## - rap
-## - nl
-##
-auto_subscribe {
-    topics = [
-        ## {
-        ##     topic = "/c/${clientid}"
-        ##     qos   = 0
-        ##     rh    = 0
-        ##     rap   = 0
-        ##     nl    = 0
-        ## },
-        ## {
-        ##     topic = "/u/${username}"
-        ## },
-        ## {
-        ##     topic = "/h/${host}"
-        ##     qos   = 2
-        ## },
-        ## {
-        ##     topic = "/p/${port}"
-        ## },
-        ## {
-        ##     topic = "/topic/abc"
-        ## },
-        ## {
-        ##     topic = "/client/${clientid}/username/${username}/host/${host}/port/${port}"
-        ## }
-    ]
-}

apps/emqx_auto_subscribe/src/emqx_auto_subscribe_app.erl

@@ -21,8 +21,8 @@
 -export([start/2, stop/1]).
 
 start(_StartType, _StartArgs) ->
-    {ok, Sup} = emqx_auto_subscribe_sup:start_link(),
     ok = emqx_auto_subscribe:load(),
+    {ok, Sup} = emqx_auto_subscribe_sup:start_link(),
     {ok, Sup}.
 
 stop(_State) ->

apps/emqx_auto_subscribe/src/emqx_auto_subscribe_schema.erl

@@ -38,7 +38,7 @@ fields("auto_subscribe") ->
         {topics,
             hoconsc:mk(
                 hoconsc:array(hoconsc:ref(?MODULE, "topic")),
-                #{desc => ?DESC(auto_subscribe)}
+                #{desc => ?DESC(auto_subscribe), default => []}
             )}
     ];
 fields("topic") ->

apps/emqx_bridge/etc/emqx_bridge.conf

@@ -1,59 +0,0 @@
-##--------------------------------------------------------------------
-## EMQX Bridge
-##--------------------------------------------------------------------
-
-## MQTT bridges to/from another MQTT broker
-#bridges.mqtt.my_ingress_mqtt_bridge {
-#    enable = true
-#    connector = "mqtt:my_mqtt_connector"
-#    direction = ingress
-#    ## topic mappings for this bridge
-#    remote_topic = "aws/#"
-#    remote_qos = 1
-#    local_topic = "from_aws/${topic}"
-#    local_qos = "${qos}"
-#    payload = "${payload}"
-#    retain = "${retain}"
-#}
-#
-#bridges.mqtt.my_egress_mqtt_bridge {
-#    enable = true
-#    connector = "mqtt:my_mqtt_connector"
-#    direction = egress
-#    ## topic mappings for this bridge
-#    local_topic = "emqx/#"
-#    remote_topic = "from_emqx/${topic}"
-#    remote_qos = "${qos}"
-#    payload = "${payload}"
-#    retain = false
-#}
-#
-## WebHook to an HTTP server
-#bridges.webhook.my_webhook {
-#    enable = true
-#    direction = egress
-#    ## NOTE: we cannot use placehodler variables in the `scheme://host:port` part of the url
-#    url = "http://localhost:9901/messages/${topic}"
-#    request_timeout = "15s"
-#    connect_timeout = "15s"
-#    max_retries = 3
-#    retry_interval = "10s"
-#    pool_type = "random"
-#    pool_size = 4
-#    enable_pipelining = true
-#    ssl {
-#        enable = false
-#        keyfile = "{{ platform_etc_dir }}/certs/client-key.pem"
-#        certfile = "{{ platform_etc_dir }}/certs/client-cert.pem"
-#        cacertfile = "{{ platform_etc_dir }}/certs/cacert.pem"
-#    }
-#
-#    local_topic = "emqx_http/#"
-#    ## the following config entries can use placehodler variables:
-#    ##   url, method, body, headers
-#    method = post
-#    body = "${payload}"
-#    headers {
-#        "content-type": "application/json"
-#    }
-#}

apps/emqx_conf/etc/emqx_conf.conf

@@ -6,845 +6,23 @@
 ##
 ## The *-override.conf files are overwritten at runtime when changes
 ## are made from EMQX dashboard UI, management HTTP API, or CLI.
+## All configuration details can be found in emqx.conf.example
 
-##==================================================================
-## Node
-##==================================================================
 node {
-  ## Node name.
-  ## See: http://erlang.org/doc/reference_manual/distributed.html
-  ##
-  ## @doc node.name
-  ## ValueType: NodeName
-  ## Default: emqx@127.0.0.1
-  name = "emqx@127.0.0.1"
-
-  ## Cookie for distributed node communication.
-  ##
-  ## @doc node.cookie
-  ## ValueType: String
-  ## Default: emqxsecretcookie
+  name: "emqx@127.0.0.1"
   cookie = emqxsecretcookie
-
-  ## Data dir for the node
-  ##
-  ## @doc node.data_dir
-  ## ValueType: Folder
-  ## Default: "{{ platform_data_dir }}"
   data_dir = "{{ platform_data_dir }}"
-
-  ## Location of crash dump file.
-  ##
-  ## @doc node.crash_dump_file
-  ## ValueType: File
-  ## Default: "{{ platform_log_dir }}/erl_crash.dump"
-  crash_dump_file = "{{ platform_log_dir }}/erl_crash.dump"
-
-  ## The number of seconds that the broker is allowed to spend writing
-  ## a crash dump
-  ##
-  ## @doc node.crash_dump_seconds
-  ## ValueType: seconds
-  ## Default: 30s
-  crash_dump_seconds = 30s
-
-  ## The maximum size of a crash dump file in bytes.
-  ##
-  ## @doc node.crash_dump_bytes
-  ## ValueType: bytes
-  ## Default: 100MB
-  crash_dump_bytes = 100MB
-
-  ## Global GC Interval.
-  ##
-  ## @doc node.global_gc_interval
-  ## ValueType: Duration
-  ## Default: 15m
-  global_gc_interval = 15m
-
-  ## Sets the etc directory
   etc_dir = "{{ platform_etc_dir }}"
-
-  ## Sets the net_kernel tick time in seconds.
-  ## Notice that all communicating nodes are to have the same
-  ## TickTime value specified.
-  ##
-  ## See: http://www.erlang.org/doc/man/kernel_app.html#net_ticktime
-  ##
-  ## @doc node.dist_net_ticktime
-  ## ValueType: Number
-  ## Default: 2m
-  dist_net_ticktime = 2m
-
-  ## Sets the maximum depth of call stack back-traces in the exit
-  ## reason element of 'EXIT' tuples.
-  ## The flag also limits the stacktrace depth returned by
-  ## process_info item current_stacktrace.
-  ##
-  ## @doc node.backtrace_depth
-  ## ValueType: Integer
-  ## Range: [0,1024]
-  ## Default: 23
-  backtrace_depth = 23
-
-  ## Comma-separated list of applications to start with emqx_machine.
-  ## These applications may restart on cluster leave/join.
-  ##
-  ## @doc node.applications
-  ## ValueType: String
-  ## Default: "gproc, esockd, ranch, cowboy, emqx"
-  applications = "{{ emqx_machine_boot_apps }}"
-
-  cluster_call {
-    retry_interval = 1s
-    max_history = 100
-    cleanup_interval = 5m
-  }
-
-  ## Database backend
-  ##
-  ## @doc node.db_backend
-  ## ValueType: mnesia | rlog
-  ## Default: rlog
-  db_backend = rlog
-
-  ## RLOG role
-  ##
-  ## @doc node.db_role
-  ## ValueType: core | replicant
-  ## Default: core
-  db_role = core
-}
-
-##==================================================================
-## Cluster
-##==================================================================
-cluster {
-  ## Cluster name.
-  ##
-  ## @doc cluster.name
-  ## ValueType: String
-  ## Default: emqxcl
-  name = emqxcl
-
-  ## Enable cluster autoheal from network partition.
-  ##
-  ## @doc cluster.autoheal
-  ## ValueType: Boolean
-  ## Default: true
-  autoheal = true
-
-  ## Autoclean down node. A down node will be removed from the cluster
-  ## if this value > 0.
-  ##
-  ## @doc cluster.autoclean
-  ## ValueType: Duration
-  ## Default: 5m
-  autoclean = 5m
-
-  ## Node discovery strategy to join the cluster.
-  ##
-  ## @doc cluster.discovery_strategy
-  ## ValueType: manual | static | mcast | dns | etcd | k8s
-  ##   - manual: Manual join command
-  ##   - static: Static node list
-  ##   - mcast:  IP Multicast
-  ##   - dns:    DNS A Record
-  ##   - etcd:   etcd
-  ##   - k8s:    Kubernetes
-  ##
-  ## Default: manual
-  discovery_strategy = manual
-
-  ## Replicant core nodes
-  ##
-  ## @doc cluster.core_nodes
-  ## ValueType: comma-separated node list
-  ## Default: ""
-  core_nodes = ""
-
-  ##----------------------------------------------------------------
-  ## Cluster using static node list
-  ##----------------------------------------------------------------
-  static {
-    ## Node list of the cluster
-    ##
-    ## @doc cluster.static.seeds
-    ## ValueType: Array<NodeName>
-    ## Default: []
-    seeds = ["emqx1@127.0.0.1", "emqx2@127.0.0.1"]
-  }
-
-  ##----------------------------------------------------------------
-  ## Cluster using IP Multicast
-  ##----------------------------------------------------------------
-  mcast {
-    ## IP Multicast Address.
-    ##
-    ## @doc cluster.mcast.addr
-    ## ValueType: IPAddress
-    ## Default: "239.192.0.1"
-    addr = "239.192.0.1"
-
-    ## Multicast Ports.
-    ##
-    ## @doc cluster.mcast.ports
-    ## ValueType: Array<Port>
-    ## Default: [4369, 4370]
-    ports = [4369, 4370]
-
-    ## Multicast Iface.
-    ##
-    ## @doc cluster.mcast.iface
-    ## ValueType: IPAddress
-    ## Default: "0.0.0.0"
-    iface = "0.0.0.0"
-
-    ## Multicast Ttl.
-    ##
-    ## @doc cluster.mcast.ttl
-    ## ValueType: Integer
-    ## Range: [0,255]
-    ## Default: 255
-    ttl = 255
-
-    ## Multicast loop.
-    ##
-    ## @doc cluster.mcast.loop
-    ## ValueType: Boolean
-    ## Default: true
-    loop = true
-  }
-
-  ##----------------------------------------------------------------
-  ## Cluster using DNS A records
-  ##----------------------------------------------------------------
-  dns {
-    ## DNS name.
-    ##
-    ## @doc cluster.dns.name
-    ## ValueType: String
-    ## Default: localhost
-    name = localhost
-
-    ## The App name is used to build 'node.name' with IP address.
-    ##
-    ## @doc cluster.dns.app
-    ## ValueType: String
-    ## Default: emqx
-    app = emqx
-  }
-
-  ##----------------------------------------------------------------
-  ## Cluster using etcd
-  ##----------------------------------------------------------------
-  etcd {
-    ## Etcd server list, separated by ','.
-    ##
-    ## @doc cluster.etcd.server
-    ## ValueType: URL
-    ## Required: true
-    server = "http://127.0.0.1:2379"
-
-    ## The prefix helps build nodes path in etcd. Each node in the cluster
-    ## will create a path in etcd: v2/keys/<prefix>/<name>/<node.name>
-    ##
-    ## @doc cluster.etcd.prefix
-    ## ValueType: String
-    ## Default: emqxcl
-    prefix = emqxcl
-
-    ## The TTL for node's path in etcd.
-    ##
-    ## @doc cluster.etcd.node_ttl
-    ## ValueType: Duration
-    ## Default: 1m
-    node_ttl = 1m
-
-    ## Path to the file containing the user's private PEM-encoded key.
-    ##
-    ## @doc cluster.etcd.ssl.keyfile
-    ## ValueType: File
-    ## Default: "{{ platform_etc_dir }}/certs/key.pem"
-    ssl.keyfile = "{{ platform_etc_dir }}/certs/key.pem"
-
-    ## Path to a file containing the user certificate.
-    ##
-    ## @doc cluster.etcd.ssl.certfile
-    ## ValueType: File
-    ## Default: "{{ platform_etc_dir }}/certs/cert.pem"
-    ssl.certfile = "{{ platform_etc_dir }}/certs/cert.pem"
-
-    ## Path to the file containing PEM-encoded CA certificates. The CA certificates
-    ## are used during server authentication and when building the client certificate chain.
-    ##
-    ## @doc cluster.etcd.ssl.cacertfile
-    ## ValueType: File
-    ## Default: "{{ platform_etc_dir }}/certs/cacert.pem"
-    ssl.cacertfile = "{{ platform_etc_dir }}/certs/cacert.pem"
-  }
-
-  ##----------------------------------------------------------------
-  ## Cluster using Kubernetes
-  ##----------------------------------------------------------------
-  k8s {
-    ## Kubernetes API server list, separated by ','.
-    ##
-    ## @doc cluster.k8s.apiserver
-    ## ValueType: URL
-    ## Required: true
-    apiserver = "http://10.110.111.204:8080"
-
-    ## The service name helps lookup EMQ nodes in the cluster.
-    ##
-    ## @doc cluster.k8s.service_name
-    ## ValueType: String
-    ## Default: emqx
-    service_name = emqx
-
-    ## The address type is used to extract host from k8s service.
-    ##
-    ## @doc cluster.k8s.address_type
-    ## ValueType: ip | dns | hostname
-    ## Default: ip
-    address_type = ip
-
-    ## The app name helps build 'node.name'.
-    ##
-    ## @doc cluster.k8s.app_name
-    ## ValueType: String
-    ## Default: emqx
-    app_name = emqx
-
-    ## The suffix added to dns and hostname get from k8s service
-    ##
-    ## @doc cluster.k8s.suffix
-    ## ValueType: String
-    ## Default: "pod.local"
-    suffix = "pod.local"
-
-    ## Kubernetes Namespace
-    ##
-    ## @doc cluster.k8s.namespace
-    ## ValueType: String
-    ## Default: default
-    namespace = default
-  }
 }
 
-##==================================================================
-## Log
-##==================================================================
 log {
-  ##----------------------------------------------------------------
-  ## The console log handler send log messages to emqx console
-  ##----------------------------------------------------------------
-  console_handler {
-    ## Log to single line
-    ## @doc log.console_handler.<name>.enable
-    ## ValueType: Boolean
-    ## Default: false
-    enable = false
-
-    ## The log level of this handler
-    ## All the log messages with levels lower than this level will
-    ## be dropped.
-    ##
-    ## @doc log.console_handler.<name>.level
-    ## ValueType: debug | info | notice | warning | error | critical | alert | emergency
-    ## Default: warning
-    level = warning
-
-    ## Timezone offset to display in logs
-    ##
-    ## @doc log.console_handler.<name>.time_offset
-    ## ValueType: system | utc | String
-    ##  - "system" use system zone
-    ##  - "utc" for Universal Coordinated Time (UTC)
-    ##  - "+hh:mm" or "-hh:mm" for a specified offset
-    ## Default: system
-    time_offset = system
-
-    ## Limits the total number of characters printed for each log event.
-    ##
-    ## @doc log.console_handler.<name>.chars_limit
-    ## ValueType: unlimited | Integer
-    ## Range: [0, +Inf)
-    ## Default: unlimited
-    chars_limit = unlimited
-
-    ## Maximum depth for Erlang term log formatting
-    ## and Erlang process message queue inspection.
-    ##
-    ## @doc log.console_handler.<name>.max_depth
-    ## ValueType: unlimited | Integer
-    ## Default: 100
-    max_depth = 100
-
-    ## Log formatter
-    ## @doc log.console_handler.<name>.formatter
-    ## ValueType: text | json
-    ## Default: text
-    formatter = text
-
-    ## Log to single line
-    ## @doc log.console_handler.<name>.single_line
-    ## ValueType: Boolean
-    ## Default: true
-    single_line = true
-
-    ## The max allowed queue length before switching to sync mode.
-    ##
-    ## Log overload protection parameter. If the message queue grows
-    ## larger than this value the handler switches from anync to sync mode.
-    ##
-    ## @doc log.console_handler.<name>.sync_mode_qlen
-    ## ValueType: Integer
-    ## Range: [0, ${log.console_handler.<name>.drop_mode_qlen}]
-    ## Default: 100
-    sync_mode_qlen = 100
-
-    ## The max allowed queue length before switching to drop mode.
-    ##
-    ## Log overload protection parameter. When the message queue grows
-    ## larger than this threshold, the handler switches to a mode in which
-    ## it drops all new events that senders want to log.
-    ##
-    ## @doc log.console_handler.<name>.drop_mode_qlen
-    ## ValueType: Integer
-    ## Range: [${log.console_handler.<name>.sync_mode_qlen}, ${log.console_handler.<name>.flush_qlen}]
-    ## Default: 3000
-    drop_mode_qlen = 3000
-
-    ## The max allowed queue length before switching to flush mode.
-    ##
-    ## Log overload protection parameter. If the length of the message queue
-    ## grows larger than this threshold, a flush (delete) operation takes place.
-    ## To flush events, the handler discards the messages in the message queue
-    ## by receiving them in a loop without logging.
-    ##
-    ## @doc log.console_handler.<name>.flush_qlen
-    ## ValueType: Integer
-    ## Range: [${log.console_handler.<name>.drop_mode_qlen}, infinity)
-    ## Default: 8000
-    flush_qlen = 8000
-
-    ## Kill the log handler when it gets overloaded.
-    ##
-    ## Log overload protection parameter. It is possible that a handler,
-    ## even if it can successfully manage peaks of high load without crashing,
-    ## can build up a large message queue, or use a large amount of memory.
-    ## We could kill the log handler in these cases and restart it after a
-    ## few seconds.
-    ##
-    ## @doc log.console_handler.<name>.overload_kill.enable
-    ## ValueType: Boolean
-    ## Default: true
-    overload_kill.enable = true
-
-    ## The max allowed queue length before killing the log handler.
-    ##
-    ## Log overload protection parameter. This is the maximum allowed queue
-    ## length. If the message queue grows larger than this, the handler
-    ## process is terminated.
-    ##
-    ## @doc log.console_handler.<name>.overload_kill.qlen
-    ## ValueType: Integer
-    ## Range: [0, 1048576]
-    ## Default: 20000
-    overload_kill.qlen = 20000
-
-    ## The max allowed memory size before killing the log handler.
-    ##
-    ## Log overload protection parameter. This is the maximum memory size
-    ## that the handler process is allowed to use. If the handler grows
-    ## larger than this, the process is terminated.
-    ##
-    ## @doc log.console_handler.<name>.overload_kill.mem_size
-    ## ValueType: Size
-    ## Default: 30MB
-    overload_kill.mem_size = 30MB
-
-    ## Restart the log handler after some seconds.
-    ##
-    ## Log overload protection parameter. If the handler is terminated,
-    ## it restarts automatically after a delay specified in seconds.
-    ##
-    ## @doc log.console_handler.<name>.overload_kill.restart_after
-    ## ValueType: Duration
-    ## Default: 5s
-    overload_kill.restart_after = 5s
-
-    ## Controlling Bursts of Log Requests.
-    ##
-    ## Log overload protection parameter. Large bursts of log events - many
-    ## events received by the handler under a short period of time - can
-    ## potentially cause problems. By specifying the maximum number of events
-    ## to be handled within a certain time frame, the handler can avoid
-    ## choking the log with massive amounts of printouts.
-    ##
-    ## Note that there would be no warning if any messages were
-    ## dropped because of burst control.
-    ##
-    ## @doc log.console_handler.<name>.burst_limit.enable
-    ## ValueType: Boolean
-    ## Default: false
-    burst_limit.enable = false
-
-    ## This config controls the maximum number of events to handle within
-    ## a time frame. After the limit is reached, successive events are
-    ## dropped until the end of the time frame defined by `window_time`.
-    ##
-    ## @doc log.console_handler.<name>.burst_limit.max_count
-    ## ValueType: Integer
-    ## Default: 10000
-    burst_limit.max_count = 10000
-
-    ## See the previous description of burst_limit_max_count.
-    ##
-    ## @doc log.console_handler.<name>.burst_limit.window_time
-    ## ValueType: duration
-    ## Default: 1s
-    burst_limit.window_time = 1s
-  }
-
-  ##----------------------------------------------------------------
-  ## The file log handlers send log messages to files
-  ##----------------------------------------------------------------
-  ## file_handlers.<name>
   file_handlers.default {
-    enable = true
-    ## The log level filter of this handler
-    ## All the log messages with levels lower than this level will
-    ## be dropped.
-    ##
-    ## @doc log.file_handlers.<name>.level
-    ## ValueType: debug | info | notice | warning | error | critical | alert | emergency
-    ## Default: warning
     level = warning
-
-    ## The log file for specified level.
-    ##
-    ## If `rotation` is disabled, this is the file of the log files.
-    ##
-    ## If `rotation` is enabled, this is the base name of the files.
-    ## Each file in a rotated log is named <base_name>.N, where N is an integer.
-    ##
-    ## Note: Log files for a specific log level will only contain all the logs
-    ##       that higher than or equal to that level
-    ##
-    ## @doc log.file_handlers.<name>.file
-    ## ValueType: File
-    ## Required: true
     file = "{{ platform_log_dir }}/emqx.log"
-
-    ## Enables the log rotation.
-    ## With this enabled, new log files will be created when the current
-    ## log file is full, max to `rotation_count` files will be created.
-    ##
-    ## @doc log.file_handlers.<name>.rotation.enable
-    ## ValueType: Boolean
-    ## Default: true
-    rotation.enable = true
-
-    ## Maximum rotation count of log files.
-    ##
-    ## @doc log.file_handlers.<name>.rotation.count
-    ## ValueType: Integer
-    ## Range: [1, 2048]
-    ## Default: 10
-    rotation.count = 10
-
-    ## Maximum size of each log file.
-    ##
-    ## If the max_size reached and `rotation` is disabled, the handler
-    ## will stop sending log messages, if the `rotation` is enabled,
-    ## the file rotates.
-    ##
-    ## @doc log.file_handlers.<name>.max_size
-    ## ValueType: Size | infinity
-    ## Default: 10MB
-    max_size = 10MB
-
-    ## Timezone offset to display in logs
-    ##
-    ## @doc log.file_handlers.<name>.time_offset
-    ## ValueType: system | utc | String
-    ##  - "system" use system zone
-    ##  - "utc" for Universal Coordinated Time (UTC)
-    ##  - "+hh:mm" or "-hh:mm" for a specified offset
-    ## Default: system
-    time_offset = system
-
-    ## Limits the total number of characters printed for each log event.
-    ##
-    ## @doc log.file_handlers.<name>.chars_limit
-    ## ValueType: unlimited | Integer
-    ## Range: [0, +Inf)
-    ## Default: unlimited
-    chars_limit = unlimited
-
-    ## Maximum depth for Erlang term log formatting
-    ## and Erlang process message queue inspection.
-    ##
-    ## @doc log.file_handlers.<name>.max_depth
-    ## ValueType: unlimited | Integer
-    ## Default: 100
-    max_depth = 100
-
-    ## Log formatter
-    ## @doc log.file_handlers.<name>.formatter
-    ## ValueType: text | json
-    ## Default: text
-    formatter = text
-
-    ## Log to single line
-    ## @doc log.file_handlers.<name>.single_line
-    ## ValueType: Boolean
-    ## Default: true
-    single_line = true
-
-    ## The max allowed queue length before switching to sync mode.
-    ##
-    ## Log overload protection parameter. If the message queue grows
-    ## larger than this value the handler switches from anync to sync mode.
-    ##
-    ## @doc log.file_handlers.<name>.sync_mode_qlen
-    ## ValueType: Integer
-    ## Range: [0, ${log.file_handlers.<name>.drop_mode_qlen}]
-    ## Default: 100
-    sync_mode_qlen = 100
-
-    ## The max allowed queue length before switching to drop mode.
-    ##
-    ## Log overload protection parameter. When the message queue grows
-    ## larger than this threshold, the handler switches to a mode in which
-    ## it drops all new events that senders want to log.
-    ##
-    ## @doc log.file_handlers.<name>.drop_mode_qlen
-    ## ValueType: Integer
-    ## Range: [${log.file_handlers.<name>.sync_mode_qlen}, ${log.file_handlers.<name>.flush_qlen}]
-    ## Default: 3000
-    drop_mode_qlen = 3000
-
-    ## The max allowed queue length before switching to flush mode.
-    ##
-    ## Log overload protection parameter. If the length of the message queue
-    ## grows larger than this threshold, a flush (delete) operation takes place.
-    ## To flush events, the handler discards the messages in the message queue
-    ## by receiving them in a loop without logging.
-    ##
-    ## @doc log.file_handlers.<name>.flush_qlen
-    ## ValueType: Integer
-    ## Range: [${log.file_handlers.<name>.drop_mode_qlen}, infinity)
-    ## Default: 8000
-    flush_qlen = 8000
-
-    ## Kill the log handler when it gets overloaded.
-    ##
-    ## Log overload protection parameter. It is possible that a handler,
-    ## even if it can successfully manage peaks of high load without crashing,
-    ## can build up a large message queue, or use a large amount of memory.
-    ## We could kill the log handler in these cases and restart it after a
-    ## few seconds.
-    ##
-    ## @doc log.file_handlers.<name>.overload_kill.enable
-    ## ValueType: Boolean
-    ## Default: true
-    overload_kill.enable = true
-
-    ## The max allowed queue length before killing the log handler.
-    ##
-    ## Log overload protection parameter. This is the maximum allowed queue
-    ## length. If the message queue grows larger than this, the handler
-    ## process is terminated.
-    ##
-    ## @doc log.file_handlers.<name>.overload_kill.qlen
-    ## ValueType: Integer
-    ## Range: [0, 1048576]
-    ## Default: 20000
-    overload_kill.qlen = 20000
-
-    ## The max allowed memory size before killing the log handler.
-    ##
-    ## Log overload protection parameter. This is the maximum memory size
-    ## that the handler process is allowed to use. If the handler grows
-    ## larger than this, the process is terminated.
-    ##
-    ## @doc log.file_handlers.<name>.overload_kill.mem_size
-    ## ValueType: Size
-    ## Default: 30MB
-    overload_kill.mem_size = 30MB
-
-    ## Restart the log handler after some seconds.
-    ##
-    ## Log overload protection parameter. If the handler is terminated,
-    ## it restarts automatically after a delay specified in seconds.
-    ##
-    ## @doc log.file_handlers.<name>.overload_kill.restart_after
-    ## ValueType: Duration
-    ## Default: 5s
-    overload_kill.restart_after = 5s
-
-    ## Controlling Bursts of Log Requests.
-    ##
-    ## Log overload protection parameter. Large bursts of log events - many
-    ## events received by the handler under a short period of time - can
-    ## potentially cause problems. By specifying the maximum number of events
-    ## to be handled within a certain time frame, the handler can avoid
-    ## choking the log with massive amounts of printouts.
-    ##
-    ## Note that there would be no warning if any messages were
-    ## dropped because of burst control.
-    ##
-    ## @doc log.file_handlers.<name>.burst_limit.enable
-    ## ValueType: Boolean
-    ## Default: false
-    burst_limit.enable = false
-
-    ## This config controls the maximum number of events to handle within
-    ## a time frame. After the limit is reached, successive events are
-    ## dropped until the end of the time frame defined by `window_time`.
-    ##
-    ## @doc log.file_handlers.<name>.burst_limit.max_count
-    ## ValueType: Integer
-    ## Default: 10000
-    burst_limit.max_count = 10000
-
-    ## See the previous description of burst_limit_max_count.
-    ##
-    ## @doc log.file_handlers.<name>.burst_limit.window_time
-    ## ValueType: duration
-    ## Default: 1s
-    burst_limit.window_time = 1s
   }
 }
 
-##==================================================================
-## RPC
-##==================================================================
-rpc {
-  ## RPC Mode.
-  ##
-  ## @doc rpc.mode
-  ## ValueType: sync | async
-  ## Default: async
-  mode = async
-
-  ## Max batch size of async RPC requests.
-  ##
-  ## NOTE: RPC batch won't work when rpc.mode = sync
-  ## Zero value disables rpc batching.
-  ##
-  ## @doc rpc.async_batch_size
-  ## ValueType: Integer
-  ## Range: [0, 1048576]
-  ## Default: 0
-  async_batch_size = 256
-
-  ## RPC port discovery
-  ##
-  ## The strategy for discovering the RPC listening port of
-  ## other nodes.
-  ##
-  ## @doc cluster.discovery_strategy
-  ## ValueType: manual | stateless
-  ##   - manual: discover ports by `tcp_server_port`.
-  ##   - stateless: discover ports in a stateless manner.
-  ##     If node name is `emqx<N>@127.0.0.1`, where the `<N>` is
-  ##     an integer, then the listening port will be `5370 + <N>`
-  ##
-  ## Default: `stateless`.
-  port_discovery = stateless
-
-  ## TCP server port for RPC.
-  ##
-  ## Only takes effect when `rpc.port_discovery` = `manual`.
-  ##
-  ## @doc rpc.tcp_server_port
-  ## ValueType: Integer
-  ## Range: [1024-65535]
-  ## Defaults: 5369
-  tcp_server_port = 5369
-
-  ## Number of outgoing RPC connections.
-  ##
-  ## Set this to 1 to keep the message order sent from the same
-  ## client.
-  ##
-  ## @doc rpc.tcp_client_num
-  ## ValueType: Integer
-  ## Range: [1, 256]
-  ## Defaults: 10
-  tcp_client_num = 10
-
-  ## RCP Client connect timeout.
-  ##
-  ## @doc rpc.connect_timeout
-  ## ValueType: Duration
-  ## Default: 5s
-  connect_timeout = 5s
-
-  ## TCP send timeout of RPC client and server.
-  ##
-  ## @doc rpc.send_timeout
-  ## ValueType: Duration
-  ## Default: 5s
-  send_timeout = 5s
-
-  ## Authentication timeout
-  ##
-  ## @doc rpc.authentication_timeout
-  ## ValueType: Duration
-  ## Default: 5s
-  authentication_timeout = 5s
-
-  ## Default receive timeout for call() functions
-  ##
-  ## @doc rpc.call_receive_timeout
-  ## ValueType: Duration
-  ## Default: 15s
-  call_receive_timeout = 15s
-
-  ## Socket idle keepalive.
-  ##
-  ## @doc rpc.socket_keepalive_idle
-  ## ValueType: Duration
-  ## Default: 900s
-  socket_keepalive_idle = 900s
-
-  ## TCP Keepalive probes interval.
-  ##
-  ## @doc rpc.socket_keepalive_interval
-  ## ValueType: Duration
-  ## Default: 75s
-  socket_keepalive_interval = 75s
-
-  ## Probes lost to close the connection
-  ##
-  ## @doc rpc.socket_keepalive_count
-  ## ValueType: Integer
-  ## Default: 9
-  socket_keepalive_count = 9
-
-  ## Size of TCP send buffer.
-  ##
-  ## @doc rpc.socket_sndbuf
-  ## ValueType: Size
-  ## Default: 1MB
-  socket_sndbuf = 1MB
-
-  ## Size of TCP receive buffer.
-  ##
-  ## @doc rpc.socket_recbuf
-  ## ValueType: Size
-  ## Default: 1MB
-  socket_recbuf = 1MB
-
-  ## Size of user-level software socket buffer.
-  ##
-  ## @doc rpc.socket_buffer
-  ## ValueType: Size
-  ## Default: 1MB
-  socket_buffer = 1MB
+cluster {
+  name = emqxcl
+  discovery_strategy = manual
 }

apps/emqx_conf/src/emqx_conf.erl

@@ -20,7 +20,7 @@
 -include_lib("hocon/include/hoconsc.hrl").
 
 -export([add_handler/2, remove_handler/1]).
--export([get/1, get/2, get_raw/2, get_all/1]).
+-export([get/1, get/2, get_raw/1, get_raw/2, get_all/1]).
 -export([get_by_node/2, get_by_node/3]).
 -export([update/3, update/4]).
 -export([remove/2, remove/3]).
@@ -54,6 +54,10 @@ get(KeyPath, Default) ->
 get_raw(KeyPath, Default) ->
     emqx_config:get_raw(KeyPath, Default).
 
+-spec get_raw(emqx_map_lib:config_key_path()) -> term().
+get_raw(KeyPath) ->
+    emqx_config:get_raw(KeyPath).
+
 %% @doc Returns all values in the cluster.
 -spec get_all(emqx_map_lib:config_key_path()) -> #{node() => term()}.
 get_all(KeyPath) ->

apps/emqx_conf/src/emqx_conf_schema.erl

@@ -801,7 +801,7 @@ fields("log") ->
             )}
     ];
 fields("console_handler") ->
-    log_handler_common_confs();
+    log_handler_common_confs(false);
 fields("log_file_handler") ->
     [
         {"file",
@@ -825,7 +825,7 @@ fields("log_file_handler") ->
                     desc => ?DESC("log_file_handler_max_size")
                 }
             )}
-    ] ++ log_handler_common_confs();
+    ] ++ log_handler_common_confs(true);
 fields("log_rotation") ->
     [
         {"enable",
@@ -1063,13 +1063,13 @@ tr_logger(Conf) ->
         ],
     [{handler, default, undefined}] ++ ConsoleHandler ++ FileHandlers.
 
-log_handler_common_confs() ->
+log_handler_common_confs(Enable) ->
     [
         {"enable",
             sc(
                 boolean(),
                 #{
-                    default => false,
+                    default => Enable,
                     desc => ?DESC("common_handler_enable")
                 }
             )},

apps/emqx_connector/etc/emqx_connector.conf

@@ -1,23 +0,0 @@
-#connectors.mqtt.my_mqtt_connector {
-#    mode = cluster_shareload
-#    server = "127.0.0.1:1883"
-#    proto_ver = "v4"
-#    username = "username1"
-#    password = ""
-#    clean_start = true
-#    keepalive = 300
-#    retry_interval = "30s"
-#    max_inflight = 32
-#    reconnect_interval = "30s"
-#    replayq {
-#        dir = "{{ platform_data_dir }}/replayq/bridge_mqtt/"
-#        seg_bytes = "100MB"
-#        offload = false
-#    }
-#    ssl {
-#        enable = false
-#        keyfile = "{{ platform_etc_dir }}/certs/client-key.pem"
-#        certfile = "{{ platform_etc_dir }}/certs/client-cert.pem"
-#        cacertfile = "{{ platform_etc_dir }}/certs/cacert.pem"
-#    }
-#}

apps/emqx_dashboard/src/emqx_dashboard_schema.erl

@@ -49,7 +49,7 @@ fields("dashboard") ->
             sc(
                 emqx_schema:duration(),
                 #{
-                    default => "30m",
+                    default => "60m",
                     desc => ?DESC(token_expired_time)
                 }
             )},

apps/emqx_exhook/etc/emqx_exhook.conf

@@ -1,46 +0,0 @@
-##====================================================================
-## EMQX Hooks
-##====================================================================
-
-exhook {
-
-    servers = [
-    ##{
-    ## name = default
-    ##
-    ## Whether to automatically reconnect (initialize) the gRPC server
-    ## When gRPC is not available, exhook tries to request the gRPC service at
-    ## that interval and reinitialize the list of mounted hooks.
-    ##
-    ## Default: false
-    ## Value: false | Duration
-    ## auto_reconnect = 60s
-
-    ## The default value or action will be returned, while the request to
-    ## the gRPC server failed or no available grpc server running.
-    ##
-    ## Default: deny
-    ## Value: ignore | deny
-    ## failed_action = deny
-
-    ## The timeout to request grpc server
-    ##
-    ## Default: 5s
-    ## Value: Duration
-    ## request_timeout = 5s
-
-    ## url = "http://127.0.0.1:9000"
-    ## ssl {
-    ##    cacertfile: "{{ platform_etc_dir }}/certs/cacert.pem"
-    ##    certfile: "{{ platform_etc_dir }}/certs/cert.pem"
-    ##    keyfile: "{{ platform_etc_dir }}/certs/key.pem"
-    ##    }
-    ##
-    ##  The process pool size for gRPC client
-    ##
-    ##  Default: Equals cpu cores
-    ##  Value: Integer
-    ##  pool_size = 16
-    ##}
-    ]
-}

apps/emqx_gateway/etc/emqx_gateway.conf

@@ -1,7 +1 @@
-##--------------------------------------------------------------------
-## EMQX Gateway configurations
-##--------------------------------------------------------------------
 
-## No gateway by default.
-##
-## If you want to get how to config it, please see emqx_gateway.conf.example.

apps/emqx_modules/etc/emqx_modules.conf

@@ -1,40 +1 @@
 
-delayed {
-    enable = true
-    ## 0 is no limit
-    max_delayed_messages = 0
-}
-
-observer_cli {
-    enable = true
-}
-
-telemetry {
-    enable = true
-}
-
-topic_metrics: [
-    #{topic: "test/1"}
-]
-
-rewrite: [
-    # {
-    #     action = publish
-    #     source_topic = "x/#"
-    #     re = "^x/y/(.+)$"
-    #     dest_topic = "z/y/$1"
-    # },
-    # {
-    #     action = subscribe
-    #     source_topic = "x1/#"
-    #     re = "^x1/y/(.+)$"
-    #     dest_topic = "z1/y/$1"
-    # },
-    # {
-    #     action = all
-    #     source_topic = "x2/#"
-    #     re = "^x2/y/(.+)$"
-    #     dest_topic = "z2/y/$1"
-    # }
-]
-

apps/emqx_modules/src/emqx_delayed.erl

@@ -382,7 +382,7 @@ do_publish(Key = {Ts, _Id}, Now, Acc) when Ts =< Now ->
 delayed_count() -> mnesia:table_info(?TAB, size).
 
 enable(Enable) ->
-    case emqx:get_raw_config([delayed]) of
+    case emqx_conf:get_raw([delayed]) of
         #{<<"enable">> := Enable} ->
             ok;
         Cfg ->

apps/emqx_modules/src/emqx_modules_app.erl

@@ -35,7 +35,7 @@ stop(_State) ->
 maybe_enable_modules() ->
     emqx_conf:get([delayed, enable], true) andalso emqx_delayed:enable(),
     emqx_modules_conf:is_telemetry_enabled() andalso emqx_telemetry:enable(),
-    emqx_conf:get([observer_cli, enable], true) andalso emqx_observer_cli:enable(),
+    emqx_observer_cli:enable(),
     emqx_conf_cli:load(),
     ok = emqx_rewrite:enable(),
     emqx_topic_metrics:enable(),

apps/emqx_modules/src/emqx_modules_conf.erl

@@ -85,7 +85,7 @@ remove_topic_metrics(Topic) ->
 -spec is_telemetry_enabled() -> boolean().
 is_telemetry_enabled() ->
     IsOfficial = emqx_telemetry:official_version(emqx_release:version()),
-    emqx:get_config([telemetry, enable], IsOfficial).
+    emqx_conf:get([telemetry, enable], IsOfficial).
 
 -spec set_telemetry_status(boolean()) -> ok | {error, term()}.
 set_telemetry_status(Status) ->

apps/emqx_modules/src/emqx_modules_schema.erl

@@ -39,11 +39,11 @@ roots() ->
     ].
 
 fields("telemetry") ->
-    [{enable, hoconsc:mk(boolean(), #{default => false, desc => "Enable telemetry."})}];
+    [{enable, hoconsc:mk(boolean(), #{default => true, desc => "Enable telemetry."})}];
 fields("delayed") ->
     [
-        {enable, hoconsc:mk(boolean(), #{default => false, desc => ?DESC(enable)})},
-        {max_delayed_messages, sc(integer(), #{desc => ?DESC(max_delayed_messages)})}
+        {enable, hoconsc:mk(boolean(), #{default => true, desc => ?DESC(enable)})},
+        {max_delayed_messages, sc(integer(), #{desc => ?DESC(max_delayed_messages), default => 0})}
     ];
 fields("rewrite") ->
     [

apps/emqx_plugins/etc/emqx_plugins.conf

@@ -1,7 +0,0 @@
-plugins {
-    prebuilt {
-    }
-    external {
-    }
-    install_dir = "{{ platform_plugins_dir }}"
-}

apps/emqx_prometheus/etc/emqx_prometheus.conf

@@ -1,8 +0,0 @@
-##--------------------------------------------------------------------
-## emqx_prometheus for EMQX
-##--------------------------------------------------------------------
-prometheus {
-    push_gateway_server = "http://127.0.0.1:9091"
-    interval = "15s"
-    enable = false
-}

apps/emqx_psk/etc/emqx_psk.conf

@@ -1,22 +1 @@
-##--------------------------------------------------------------------
-## EMQX PSK
-##--------------------------------------------------------------------
 
-psk_authentication {
-    ## Whether to enable the PSK feature.
-    enable = false
-
-    ## If init file is specified, emqx will import PSKs from the file
-    ## into the built-in database at startup for use by the runtime.
-    ##
-    ## The file has to be structured line-by-line, each line must be in
-    ## the format: <PSKIdentity>:<SharedSecret>
-    ## init_file = "{{ platform_data_dir }}/init.psk"
-
-    ## Specifies the separator for PSKIdentity and SharedSecret in the init file.
-    ## The default is colon (:)
-    ## separator = ":"
-
-    ## The size of each chunk used to import to the built-in database from psk file
-    ## chunk_size = 50
-}

apps/emqx_psk/src/emqx_psk_schema.erl

@@ -44,6 +44,7 @@ fields() ->
         {enable,
             sc(boolean(), #{
                 default => false,
+                require => true,
                 desc => ?DESC(enable)
             })},
         {init_file,

apps/emqx_retainer/etc/emqx_retainer.conf

@@ -1,82 +0,0 @@
-##--------------------------------------------------------------------
-## EMQX Retainer
-##--------------------------------------------------------------------
-
-## Where to store the retained messages.
-##
-## Notice that all nodes in the same cluster have to be configured to
-retainer {
-  ## enable/disable emqx_retainer
-  enable = true
-
-  ## Periodic interval for cleaning up expired messages. Never clear if the value is 0.
-  ##
-  ## Value: Duration
-  ##  - h: hour
-  ##  - m: minute
-  ##  - s: second
-  ##
-  ## Examples:
-  ##  - 2h:  2 hours
-  ##  - 30m: 30 minutes
-  ##  - 20s: 20 seconds
-  ##
-  ## Default: 0s
-  msg_clear_interval = 0s
-
-  ## Message retention time. 0 means message will never be expired.
-  ##
-  ## Default: 0s
-  msg_expiry_interval = 0s
-
-  ## When the retained flag of the PUBLISH message is set and Payload is empty,
-  ## whether to continue to publish the message.
-  ## see: http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html#_Toc398718038
-  ##
-  ## Default: false
-  #stop_publish_clear_msg = false
-
-  ## The message read and deliver flow rate control
-  ## When a client subscribe to a wildcard topic, may many retained messages will be loaded.
-  ## If you don't want these data loaded to the memory all at once, you can use this to control.
-  ## The processing flow:
-  ##   load batch_read_number retained message from storage ->
-  ##    deliver ->
-  ##    repeat this, until all retianed messages are delivered
-  ##
-  flow_control {
-    ## The messages batch number per read from storage. 0 means no limit
-    ##
-    ## Default: 0
-    batch_read_number = 0
-
-    ## The number of retained message can be delivered per batch
-    ## Range: [0, 1000]
-    ## Note: If this value is too large, it may cause difficulty in applying for the token of deliver
-    ##
-    ## Default: 0
-    batch_deliver_number = 0
-  }
-
-  ## Maximum retained message size.
-  ##
-  ## Value: Bytes
-  max_payload_size = 1MB
-
-  ## Storage backend parameters
-  ##
-  ## Value: built_in_database
-  ##
-  backend {
-
-    type = built_in_database
-
-    ## storage_type: ram | disc
-    storage_type = ram
-
-    ## Maximum number of retained messages. 0 means no limit.
-    ##
-    ## Value: Number >= 0
-    max_retained_messages = 0
-    }
-}

apps/emqx_retainer/src/emqx_retainer_dispatcher.erl

@@ -111,7 +111,7 @@ start_link(Pool, Id) ->
 init([Pool, Id]) ->
     erlang:process_flag(trap_exit, true),
     true = gproc_pool:connect_worker(Pool, {Pool, Id}),
-    BucketName = emqx:get_config([retainer, flow_control, batch_deliver_limiter], undefined),
+    BucketName = emqx_conf:get([retainer, flow_control, batch_deliver_limiter], undefined),
     {ok, Limiter} = emqx_limiter_server:connect(batch, BucketName),
     {ok, #{pool => Pool, id => Id, limiter => Limiter}}.
 
@@ -151,7 +151,7 @@ handle_cast({dispatch, Context, Pid, Topic}, #{limiter := Limiter} = State) ->
     {ok, Limiter2} = dispatch(Context, Pid, Topic, undefined, Limiter),
     {noreply, State#{limiter := Limiter2}};
 handle_cast(refresh_limiter, State) ->
-    BucketName = emqx:get_config([retainer, flow_control, batch_deliver_limiter]),
+    BucketName = emqx_conf:get([retainer, flow_control, batch_deliver_limiter]),
     {ok, Limiter} = emqx_limiter_server:connect(batch, BucketName),
     {noreply, State#{limiter := Limiter}};
 handle_cast(Msg, State) ->
@@ -249,7 +249,7 @@ deliver(Result, Context, Pid, Topic, Cursor, Limiter) ->
         false ->
             {ok, Limiter};
         _ ->
-            DeliverNum = emqx:get_config([retainer, flow_control, batch_deliver_number]),
+            DeliverNum = emqx_conf:get([retainer, flow_control, batch_deliver_number], undefined),
             case DeliverNum of
                 0 ->
                     do_deliver(Result, Pid, Topic),

apps/emqx_retainer/src/emqx_retainer_schema.erl

@@ -18,7 +18,7 @@ roots() -> ["retainer"].
 
 fields("retainer") ->
     [
-        {enable, sc(boolean(), enable, false)},
+        {enable, sc(boolean(), enable, true)},
         {msg_expiry_interval,
             sc(
                 emqx_schema:duration_ms(),
@@ -31,7 +31,11 @@ fields("retainer") ->
                 msg_clear_interval,
                 "0s"
             )},
-        {flow_control, sc(hoconsc:ref(?MODULE, flow_control), flow_control)},
+        {flow_control,
+            sc(
+                ?R_REF(flow_control),
+                flow_control
+            )},
         {max_payload_size,
             sc(
                 emqx_schema:bytesize(),
@@ -48,7 +52,7 @@ fields("retainer") ->
     ];
 fields(mnesia_config) ->
     [
-        {type, sc(hoconsc:union([built_in_database]), mnesia_config_type, built_in_database)},
+        {type, sc(hoconsc:enum([built_in_database]), mnesia_config_type, built_in_database)},
         {storage_type,
             sc(
                 hoconsc:union([ram, disc]),
@@ -57,10 +61,9 @@ fields(mnesia_config) ->
             )},
         {max_retained_messages,
             sc(
-                integer(),
+                non_neg_integer(),
                 max_retained_messages,
-                0,
-                fun is_pos_integer/1
+                0
             )},
         {index_specs, fun retainer_indices/1}
     ];
@@ -68,10 +71,9 @@ fields(flow_control) ->
     [
         {batch_read_number,
             sc(
-                integer(),
+                non_neg_integer(),
                 batch_read_number,
-                0,
-                fun is_pos_integer/1
+                0
             )},
         {batch_deliver_number,
             sc(
@@ -99,27 +101,17 @@ desc(_) ->
 %%--------------------------------------------------------------------
 %% Internal functions
 %%--------------------------------------------------------------------
+
 sc(Type, DescId) ->
-    hoconsc:mk(Type, #{required => true, desc => ?DESC(DescId)}).
+    hoconsc:mk(Type, #{desc => ?DESC(DescId)}).
 
 sc(Type, DescId, Default) ->
     hoconsc:mk(Type, #{default => Default, desc => ?DESC(DescId)}).
 
-sc(Type, DescId, Default, Validator) ->
-    hoconsc:mk(Type, #{
-        default => Default,
-        desc => ?DESC(DescId),
-        validator => Validator
-    }).
-
-is_pos_integer(V) ->
-    V >= 0.
-
 backend_config() ->
-    sc(
+    hoconsc:mk(
         hoconsc:union([hoconsc:ref(?MODULE, mnesia_config)]),
-        backend,
-        mnesia_config
+        #{desc => ?DESC(backend)}
     ).
 
 retainer_indices(type) ->

apps/emqx_rule_engine/etc/emqx_rule_engine.conf

@@ -1,22 +0,0 @@
-##====================================================================
-## Rule Engine for EMQX R5.0
-##====================================================================
-rule_engine {
-    ignore_sys_message = true
-    jq_function_default_timeout = 10s
-    #rules.my_republish_rule {
-    #    description = "A simple rule that republishs MQTT messages from topic 't/1' to 't/2'"
-    #    enable = true
-    #    sql = "SELECT * FROM \"t/1\""
-    #    actions = [
-    #        {
-    #            function = republish
-    #            args = {
-    #                topic = "t/2"
-    #                qos = "${qos}"
-    #                payload = "${payload}"
-    #            }
-    #        }
-    #    ]
-    #}
-}

apps/emqx_slow_subs/etc/emqx_slow_subs.conf

@@ -1,35 +0,0 @@
-##--------------------------------------------------------------------
-## EMQX Slow Subscribers Statistics
-##--------------------------------------------------------------------
-
-slow_subs {
-    enable = false
-
-    threshold = 500ms
-    ## The latency threshold for statistics, the minimum value is 100ms
-    ##
-    ## Default: 500ms
-
-    ## The eviction time of the record, which in the statistics record table
-    ##
-    ## Default: 300s
-    expire_interval = 300s
-
-    ## The maximum number of records in the slow subscription statistics record table
-    ##
-    ## Value: 10
-    top_k_num = 10
-
-    ## The ways to calculate the latency are as follows:
-    ##
-    ## 1. whole
-    ## From the time the message arrives at EMQX until the message completes transmission
-    ##
-    ## 2.internal
-    ## From when the message arrives at EMQX until when EMQX starts delivering the message
-    ##
-    ## 3.response
-    ## From the time EMQX starts delivering the message, until the message completes transmission
-    ## Default: whole
-    stats_type = whole
-}

apps/emqx_statsd/etc/emqx_statsd.conf

@@ -1,10 +0,0 @@
-##--------------------------------------------------------------------
-## Statsd for EMQX
-##--------------------------------------------------------------------
-
-statsd {
-    enable = false
-    server = "127.0.0.1:8125"
-    sample_time_interval = "10s"
-    flush_time_interval = "10s"
-}

scripts/merge-config.escript

@@ -9,15 +9,19 @@
 %% edition due to backward-compatibility reasons.
 
 -mode(compile).
+-define(APPS, ["emqx", "emqx_dashboard", "emqx_authz"]).
 
 main(_) ->
     {ok, BaseConf} = file:read_file("apps/emqx_conf/etc/emqx_conf.conf"),
 
     Cfgs = get_all_cfgs("apps/"),
-    Conf = [merge(BaseConf, Cfgs),
-            io_lib:nl(),
-            "include emqx_enterprise.conf",
-            io_lib:nl()],
+    Conf = [
+        merge(BaseConf, Cfgs),
+        io_lib:nl(),
+        io_lib:nl(),
+        "include emqx_enterprise.conf",
+        io_lib:nl()
+    ],
     ok = file:write_file("apps/emqx_conf/etc/emqx.conf.all", Conf),
 
     EnterpriseCfgs = get_all_cfgs("lib-ee/"),
@@ -27,25 +31,33 @@ main(_) ->
 
 merge(BaseConf, Cfgs) ->
     lists:foldl(
-      fun(CfgFile, Acc) ->
-              case filelib:is_regular(CfgFile) of
-                  true ->
-                      {ok, Bin1} = file:read_file(CfgFile),
-                      [Acc, io_lib:nl(), Bin1];
-                  false -> Acc
-              end
-      end, BaseConf, Cfgs).
+        fun(CfgFile, Acc) ->
+            case filelib:is_regular(CfgFile) of
+                true ->
+                    {ok, Bin1} = file:read_file(CfgFile),
+                    case string:trim(Bin1, both) of
+                        <<>> -> Acc;
+                        Bin2 -> [Acc, io_lib:nl(), io_lib:nl(), Bin2]
+                    end;
+                false ->
+                    Acc
+            end
+        end,
+        BaseConf,
+        Cfgs
+    ).
 
 get_all_cfgs(Root) ->
-    Apps = filelib:wildcard("*", Root) -- ["emqx_machine", "emqx_conf"],
-    Dirs = [filename:join([Root, App]) || App <- Apps],
+    Apps0 = filelib:wildcard("*", Root) -- ["emqx_machine", "emqx_conf"],
+    Apps1 = (Apps0 -- ?APPS) ++ lists:reverse(?APPS),
+    Dirs = [filename:join([Root, App]) || App <- Apps1],
     lists:foldl(fun get_cfgs/2, [], Dirs).
 
 get_all_cfgs(Dir, Cfgs) ->
     Fun = fun(E, Acc) ->
-                  Path = filename:join([Dir, E]),
-                  get_cfgs(Path, Acc)
-          end,
+        Path = filename:join([Dir, E]),
+        get_cfgs(Path, Acc)
+    end,
     lists:foldl(Fun, Cfgs, filelib:wildcard("*", Dir)).
 
 get_cfgs(Dir, Cfgs) ->