b58d3e8f94
Merge pull request #10529 from zmstone/0426-ensure-buffer-worker-monitors-cassandra-conn-pid
...
0426 ensure buffer worker monitors cassandra conn pid
2023-04-27 22:54:30 +02:00
1f0148a819
Merge pull request #10524 from lafirest/fix/rocketmq_sensitive
...
fix(rocketmq): keep sensitive data safe in rocketmq logs and state
2023-04-27 10:16:05 +08:00
a8b000f062
refactor(sqlserver): support only sync mode at connector level
2023-04-26 20:44:56 +02:00
c83d630c97
fix(cassandra): ensure async calls return connection pid
...
so the buffer worker can monitor it and perform retries
if the connection restarted
2023-04-26 14:33:37 +02:00
6706fd90e1
fix(rocketmq): keep sensitive data safe in rocketmq logs and state
2023-04-26 16:10:35 +08:00
e467e082f0
fix(dynamo): remove all async callbacks of the Dynamo connector
2023-04-26 14:47:22 +08:00
dc452deaf0
Merge pull request #10506 from lafirest/fix/dynamo_default_port
...
fix(dynamo): use correct default port for different schemas
2023-04-25 18:26:44 +08:00
3bb50a5751
fix(rocketmq): fix that the update of ACL info not working
2023-04-25 16:55:03 +08:00
33c27ac2ac
fix(dynamo): use correct default port for different schemas
2023-04-25 10:50:44 +08:00
7ce04358c4
fix(Dynamo): fix DynamoDB bridge status check error
2023-04-24 17:28:33 +08:00
2b0106e047
Merge pull request #10485 from JimMoen/fix-mssql-bridge-default
...
fix: use default health check timeout for sqlserver
2023-04-23 18:20:10 +08:00
d505b65ba8
fix: use default health check timeout for sqlserver
2023-04-23 15:47:19 +08:00
6ef032026f
Merge pull request #10471 from lafirest/fix/dynamo_bridge
...
fix(dynamo): separate the implementation of connector and client of Dynamo bridge
2023-04-23 14:25:23 +08:00
d826b0921d
fix(dynamo): separate the implementation of connector and client of Dynamo bridge
2023-04-23 10:57:36 +08:00
7704995279
fix(rocketmq): expose the driver parameter `sync_timeout` into the RocketMQ bridge configuration
2023-04-21 15:10:25 +08:00
48402d0476
Merge pull request #10461 from lafirest/fix/dynamo_db_svrs
...
fix(rocketmq): allow setting multiple addresses in RocketMQ bridge
2023-04-21 14:37:37 +08:00
f602900a53
fix(rocketmq): fix that the status check of RocketMQ bridge may not accurate
2023-04-21 13:35:29 +08:00
6e12abff39
fix(rocketmq): allow setting multiple addresses in RocketMQ bridge
2023-04-20 17:58:12 +08:00
e89f4d4565
fix(dynamo): fix terminology erros
...
- Changed `username` to `aws_access_key_id`
- Changed `password` to `aws_secret_access_key`
2023-04-19 16:26:42 +08:00
bc353b0a06
fix(dynamo): change `database` to `table` in the schema of the DynamoDB bridge
...
there is no term like `database` in DynamoDB, the correct concept should be `table`
2023-04-19 15:56:29 +08:00
9fc8a498f8
chore: bump apps versions
2023-04-17 09:09:08 +02:00
4f2f0ebb6a
fix: bad ref to emqx_misc after rebase
2023-04-14 14:58:19 +02:00
9c11bfce80
refactor: rename emqx_misc to emqx_utils
2023-04-14 13:41:27 +02:00
f8e9e54393
refactor: move emqx_json to emqx_utils_json
2023-04-14 13:31:27 +02:00
8cec62bd87
fix: async reply arg list
2023-04-14 12:43:36 +08:00
65c4234829
refactor: rename instance_id, which is also PoolName
2023-04-14 10:02:48 +08:00
2d1b94f7f7
fix: file mode 755 magic number
2023-04-14 10:02:48 +08:00
675f9894ab
fix: fix single quotes not applied for single query
...
- alwasy use `emqx_plugin_libs_rule:proc_batch_sql/3` to add single quotes for string
2023-04-14 10:02:47 +08:00
f8c0aa49a2
style: make elvis and shellcheck happy
2023-04-14 10:02:47 +08:00
27fdf644aa
fix(sqlserver): let a single query be a length 1 batch
...
Need to be fixed:
`emqx_plugin_libs_rule:proc_tmpl/2` won't add single quotes for string
2023-04-14 10:02:46 +08:00
c366267b0f
test: MS SQL Server data bridge
2023-04-14 10:02:46 +08:00
5841969877
feat: implement Microsoft SQL Server bridge (e5.0)
2023-04-14 10:02:45 +08:00
8e62afecdd
chore: suite module rename
2023-04-14 09:57:00 +08:00
8ceeafb0de
chore: fix file license in lib-ee
2023-04-14 09:56:59 +08:00
9acfe00498
Merge pull request #10347 from thalesmg/refactor-kafka-bridge-dirs-v50
...
refactor(kafka_bridge): move kafka bridge into its own app
2023-04-13 13:26:36 -03:00
601564fa0a
Merge pull request #10324 from kjellwinblad/kjell/fix/EMQX-9374
...
fix: check Clickhouse connection after creation
2023-04-13 16:31:35 +02:00
0cec52d5e4
fix: check Clickhouse connection after creation
...
When pressing reconnect on a badly configured Clickhouse bridge in the
dashboard, no error message was shown. This commit fixes this issue by
testing the connection after creation and returning an error tuple if
the connection is not working.
Fixes:
https://emqx.atlassian.net/browse/EMQX-9374
2023-04-13 10:09:35 +02:00
871ee90b3e
refactor(kafka_bridge): move kafka bridge into its own app
...
Fixes https://emqx.atlassian.net/browse/EMQX-9481
2023-04-12 13:54:45 -03:00
f01e2f358b
Merge pull request #10367 from id/0411-sync-release-50-back-to-master
...
0411 sync release 50 back to master
2023-04-12 17:23:17 +02:00
bdffa925db
chore: merge upstream/master release-50
2023-04-12 15:30:20 +02:00
9560fdc5a2
chore: typo fixes
2023-04-12 14:16:40 +08:00
30bdffe318
feat: support async and batch callback for cassandra connector
2023-04-10 15:08:10 +08:00
5d5b7ea215
Merge pull request #10306 from thalesmg/enable-async-buffer-workers-all-bridges-v50
...
feat(bridges): enable async query mode for all bridges with buffer workers
2023-04-04 17:10:46 -03:00
ed31b735a8
Merge pull request #10220 from lafirest/bump/hackney
...
chore: bump hackney version
2023-04-04 10:35:09 +08:00
f3ffc02bff
feat(bridges): enable async query mode for all bridges with buffer workers
...
Fixes https://emqx.atlassian.net/browse/EMQX-9130
Since buffer workers always support async calls ("outer calls"), we
should decouple those two call modes (inner and outer), and avoid
exposing the inner call configuration to user to avoid complexity.
For bridges that currently only allow sync query modes, we should
allow them to be configured with async. That means basically all
bridge types except Kafka Producer.
2023-04-03 14:49:51 -03:00
36000abf51
refactor: relocate i18n files for apps/emqx
2023-04-03 13:12:24 +02:00
c8dca74b18
chore: bump hackney version
2023-04-03 18:41:49 +08:00
d63680cf25
Merge pull request #10307 from emqx/release-50
...
Sync release-50 back to master
2023-04-02 11:36:41 +08:00
58898ea11d
Merge pull request #10294 from kjellwinblad/kjell/feat/collection_var_syntax_mongodb/EMQX-9246
...
feat: (MongoDB bridge) use ${var} syntax in MongoDB collection field
2023-03-31 17:18:27 +02:00
fe400c7f8d
Merge pull request #10272 from kjellwinblad/kjell/better_label
...
docs: make clickhouse config label for Server URL more concise
2023-03-31 16:17:26 +02:00
Zaiming (Stone) Shi