791db44fba
chore: bump version
2023-10-30 01:48:09 +01:00
2f46e86db8
test: refactor test group generation
2023-10-30 01:43:39 +01:00
289428cc5a
refactor(kafka): rename bridge type 'kafka' to 'kafka_producer'
2023-10-30 00:19:27 +01:00
449b01ef78
feat: let bridge V2 override bridge creation opts from connector
2023-10-29 07:28:13 +01:00
1b248279fd
test(bridge_v2): test case for the local_topic feature
2023-10-28 17:59:11 +02:00
5cfe151f7c
fix: type conversion for rule with converted bridge V1 reference
...
* Make sure that a rule that refer to a bridge that has been converted to
a bridge V2 bridge gets its type converted if needed.
* Add test case for sending message to a Bridge V2 through a rule
2023-10-28 15:18:36 +02:00
e1009998c9
fix(emqx_bridge_v2): properly working start function
2023-10-28 14:00:05 +02:00
babf5f973a
fix: use populated non-raw conf when checking if bridge_v2 is enabled
2023-10-28 07:42:45 +02:00
917e13c0e9
fix: add start/stop/restart support to bridge v1 compatibility layer
2023-10-28 07:30:47 +02:00
1dea3e1cc4
test: add suite for AEH bridge v2
2023-10-27 20:00:21 +02:00
d0ffae56d7
chore: make elvis happy
2023-10-27 19:41:20 +02:00
886334e7b6
fix: bridge v1 compatiblity layer enable/disable
2023-10-27 18:51:20 +02:00
d61d80f338
fix: almost working bridge v1 compatibility layer for HTTP API
...
Most operation for the bridge V1 HTTP API compatibility layer are now
working. This has been tested by creating/deleting/updating Kafka bridge
through HTTP API, sending message to it, and resetting and checking
metrics.
The start, stop, restart, enable, disable operations still need to be
fixed.
2023-10-27 18:25:11 +02:00
f8d330c2f3
fix(bridge_v2): don't spawn buffer workers for `simple_{,a}sync_internal_buffer`
2023-10-27 10:30:03 -03:00
951184014e
test(bridge_v2): add test cases for root post config update handler callback
2023-10-27 08:42:59 -03:00
27aff47c17
fix(connector): check that there are no active channels when removing
2023-10-27 08:23:28 -03:00
5f17a8f2ce
fix(kafka): use client config for topic existence check
...
Prior to this fix, Kafka producer config was used as client config
2023-10-27 11:53:42 +02:00
f2c9739ce2
feat(bridge_v2): validate connector references when creating/updating bridges
2023-10-27 11:53:42 +02:00
04a832a80a
refactor(kafka): fix typo and take connector type from input
2023-10-27 11:53:42 +02:00
7745cb8ef7
test: fix emqx_bridge_v2_kafka_producer_SUITE
2023-10-27 11:53:42 +02:00
89812f0a7a
test(bridge_http): stablize flaky test case
2023-10-27 11:53:42 +02:00
83e05b0d77
fix(bridge_resource): use more lax parsing of bridge id
2023-10-27 11:53:42 +02:00
d574821160
fix(bridge_api): use translated config to check if bridge is enabled
2023-10-27 11:53:42 +02:00
90a23d98fe
fix: channel handling when resource not connected
2023-10-27 11:53:42 +02:00
e2aca352b6
fix(kafka): Fix server name indication config for Kafka
...
Also impoved azur event hub's doc for SNI
2023-10-27 11:53:41 +02:00
da7d495da9
test: fix emqx_connector_SUITE
2023-10-27 11:53:41 +02:00
2228a0d477
feat: port azure event hub to bridge_v2
2023-10-27 11:53:41 +02:00
f760f0a5c5
fix: backport 7b607c3300
2023-10-27 11:53:41 +02:00
b72abaf661
fix: wording from copy-paste error
2023-10-27 11:53:41 +02:00
238603a101
fix: bridge_v2 tags were still bridge
2023-10-27 11:53:41 +02:00
5aac90ab4e
fix: don't send message to channels that are not operational
2023-10-27 11:53:41 +02:00
bba5b42c99
fix: broken test cases
2023-10-27 11:53:41 +02:00
477ed11de8
fix: periodical status checks and alarms for channels
2023-10-27 11:53:41 +02:00
3cab31261e
feat: Add API endpoint /api/v5/schemas/connectors
2023-10-27 11:53:41 +02:00
36411edb42
feat: Add API endpoint /api/v5/schemas/bridges_v2
2023-10-27 11:53:41 +02:00
4ac0a76d00
test: fix emqx_resource_SUITE
2023-10-27 11:53:41 +02:00
8c30c22b02
chore: avoid invalid dynamic call error
2023-10-27 11:53:41 +02:00
ba2464769b
fix(emqx_resource): redact error reason too before logging
2023-10-27 11:53:41 +02:00
e29ba35e53
fix: typo in warning log message when remove channel error happens
2023-10-27 11:53:41 +02:00
eed44f79a6
refactor(emqx_config): check if upgrade_raw_conf is exported
2023-10-27 11:53:41 +02:00
6625754325
chore: bump app version
2023-10-27 11:53:41 +02:00
16f8848281
test: fix emqx_connector_SUITE
2023-10-27 11:53:41 +02:00
96726b5620
refactor(eqmx_config): use dynamic callback to upgrade raw config
2023-10-27 11:53:41 +02:00
38bf2ae445
fix: issues found by spellcheck script
2023-10-27 11:53:41 +02:00
2d05e3a975
fix: dialyzer problem for community edition
2023-10-27 11:53:41 +02:00
6c6c2e0cff
fix: dialyzer warnings for community edition
2023-10-27 11:53:41 +02:00
a847b043df
fix: disable bridge_v2 tests if not on enterprise
2023-10-27 11:53:41 +02:00
e72b952138
fix: problems reported by dialyzer
2023-10-27 11:53:41 +02:00
7822d7db76
fix: strange issue with `erlfmt`
2023-10-27 11:53:41 +02:00
29ca7f944f
fix: simplify by enabling check_schema
2023-10-27 11:53:41 +02:00
Zaiming (Stone) Shi