19e3f5919e
chore: release e5.0.0-beta.4
2022-09-26 19:54:01 +08:00
dfe14be8b2
chore: bump app vsns
2022-09-26 18:23:28 +08:00
4135910b42
chore: merge master into dev/ee5.0
2022-09-26 09:52:33 +08:00
f6ac4c3a76
Merge pull request #8798 from zmstone/0815-feat-add-kafka-connector
...
feat: Add Kafka connector
2022-09-24 22:57:50 +02:00
d24441b204
fix(bridges): some issues found in code review
2022-09-23 18:32:39 +08:00
7b601bf970
chore: delete bad parse_bridge function clause
2022-09-23 11:53:02 +02:00
2984397e73
chore: apps vsn bump
2022-09-23 17:09:15 +08:00
fc3fdfb994
fix(build): apply PR#8956 changes
2022-09-23 17:09:10 +08:00
adc67b165b
test: test cases for Kafka bridge REST API
2022-09-23 10:09:07 +02:00
85835256f1
Merge tag 'v5.0.8' into merge-release-v5.0.8-into-master
2022-09-23 16:06:44 +08:00
516d60c7da
build: fix deps consistency check
2022-09-23 09:00:17 +02:00
5ef1a978bd
chore: bump slow subs version && update CHANGES
2022-09-22 17:59:11 +08:00
89af9c4a5f
fix(slow_subs): fix timestamp unit error and update config not work
...
1. The unit of `deliver_begin_at` is incorrectly used the `seconds`, the resulting is incorrect when `stats_type` is `internal` or `response`
2. The config update doesn't actually take effect, the `load` function always used the old config
2022-09-22 17:57:51 +08:00
9ea0147a8c
feat(rule engine jq function): config for changing implementation
...
This commit adds a rule engine configuration option for changing the
implementation module used for the rule engine function jq. The two
options are `jq_port` (uses Erlang port programs to interact with jq)
and `jq_nif` (uses an Erlang NIF library to interact with jq).
Thanks to @terry-xiaoyu (Xinyu Liu <506895667@qq.com>) for Chinese
translations
2022-09-22 09:02:30 +02:00
6d37fc8dcb
Merge pull request #9012 from JimMoen/rm-influxdb-udp
...
Hide influxdb udp bridge.
2022-09-22 10:33:05 +08:00
b325633390
refactor(resource): resume from queue/inflight-window with async-sending and batching
2022-09-21 22:58:47 +08:00
c11afc357e
fix(auth): use empty strings for absent placeholder values
2022-09-20 15:20:55 +03:00
8c718d891f
Merge pull request #9002 from zhongwencool/fix-listener-crash
...
fix: /listeners API crash when there are nodes still in initial conf
2022-09-20 15:25:03 +08:00
6788881642
fix: hide influxdb udp config
2022-09-20 14:46:59 +08:00
2551c51a8c
fix: ct failed
2022-09-20 11:37:49 +08:00
62957b298b
chore(ekka): Bump version to 0.13.5
2022-09-19 18:21:32 +02:00
0241185225
chore: Add test coverage for listeners API
2022-09-19 18:25:25 +08:00
386110ae1e
fix: /listeners API crash when some nodes still in init configuration
2022-09-19 15:24:36 +08:00
cc327629c3
Merge pull request #8992 from terry-xiaoyu/fast_resume_from_inflight_full
...
Fast resume from inflight full
2022-09-18 17:49:04 +08:00
c20ad3733a
fix: check for authorization on topic before publishing last will testament
...
fixes #8978
Without checking for authorization, a client can, on abnormal
termination, publish a message to any topic, including `$SYS` ones.
2022-09-16 17:31:22 -03:00
dca522d7d3
test: add tests for publishing lwt when deny_action is disconnect
2022-09-16 15:11:54 -03:00
87ab2e3a2d
fix: check conn state before sending will message
2022-09-16 15:11:54 -03:00
9aa7e826cb
refactor(resource): fast resume resource worker if inflight msgs are ACKed
2022-09-17 00:34:30 +08:00
ba37ab4938
chore: bump vsn to 5.0.8
2022-09-16 19:32:17 +08:00
8307f04c2e
refactor(resource): save inflight size into the ETS table
2022-09-16 16:52:08 +08:00
a660004fa4
fix(bridge): mqtt bridge client info `username` & `password`
...
for non configured `username` and `password`, default values `<<>>` should be
used. emqtt needs the values.
2022-09-16 15:09:51 +08:00
0336b935a0
Merge pull request #8901 from JimMoen/fix-bridge-api
...
- for connectors using ecpool, parse connect error `Reason` when start pool failed.
- Refine InfluxDB bridge desc.
2022-09-16 10:22:06 +08:00
14b5977996
feat(authz): Support `cert_common_name` and `cert_subject` in Authz
2022-09-15 18:02:54 +08:00
8054144357
chore: bump vsn
2022-09-15 10:20:25 +08:00
d5d3972ff5
chore: add test cases for MQTT Bridge reconnecting
2022-09-15 10:19:33 +08:00
0390a5e547
fix(bridge): mysql bridge error case
2022-09-15 09:36:52 +08:00
d9c9a1dec3
Merge pull request #8958 from JimMoen/fix-ssl-drop-invalid-certs
...
fix(bridge/authz/exhook): no need to drop invalid certs
2022-09-15 09:01:08 +08:00
4e211c12d3
fix(mqtt_bridge): return value of sending messages was discarded
2022-09-15 08:57:01 +08:00
8845da130e
Merge pull request #8957 from HJianBo/strip-double-quote
...
chore: support strip double quote in authn/authz
2022-09-14 17:35:41 +08:00
9ffbff11c2
Merge pull request #8956 from lafirest/fix/redis_authn
...
fix(authn_redis): Add new clause for non-existent key check
2022-09-14 17:05:34 +08:00
8590fef829
fix(authn_redis): Avoid duplicating check for non-existent keys
2022-09-14 16:30:59 +08:00
a461375b30
chore: support strip double quote in authn/authz
...
more compatibility for https://github.com/emqx/emqx/pull/8827
2022-09-14 15:25:31 +08:00
1c03c236f5
fix(mqtt_bridge): handle send_to_remote in idle state
2022-09-14 15:19:30 +08:00
f41adb0997
refactor: change some default values of resource_opts
2022-09-14 15:18:07 +08:00
62fd955a0e
fix(authn_redis): make dialyzer happy
2022-09-14 14:16:43 +08:00
f018b8ab49
fix(bridge/authz/exhook): no need to drop invalid certs
2022-09-14 14:08:55 +08:00
9e97760520
fix(authn_redis): Add new clause for non-existent key check
...
fix #8800
when the key not-existing, redis may return a list that all elements are `undefined`
2022-09-14 11:30:26 +08:00
53bc6f47e7
Merge pull request #8948 from zhongwencool/deprecated-etc-dir
...
chore: deprecated etc_dir since 5.0.8
2022-09-14 10:05:10 +08:00
0c1595be02
feat: Add Kafka connector
2022-09-13 19:46:56 +02:00
b5bf5d3adb
fix: mqtt bridge payload default value
2022-09-13 18:58:01 +08:00
Shawn