Thales Macedo Garitezi
|
46393343e2
|
chore: use `timeout_duration` types for timer fields
Fixes https://emqx.atlassian.net/browse/EMQX-10020
|
2023-06-05 11:46:38 -03:00 |
|
Thales Macedo Garitezi
|
9c3f838e14
|
Merge pull request #10841 from thalesmg/kafka-validate-key-v50
feat({kafka,pulsar}_producer): add validation for empty message key when strategy = key_dispatch
|
2023-05-30 09:37:15 -03:00 |
|
Thales Macedo Garitezi
|
9b7e473cf6
|
feat(kafka_producer): add validation for empty message key when strategy = key_dispatch
Fixes https://emqx.atlassian.net/browse/EMQX-9979
|
2023-05-26 12:02:58 -03:00 |
|
Thales Macedo Garitezi
|
0ca3f51503
|
fix(kafka): improve shutdown and health check logs during shutdown
|
2023-05-25 16:38:09 -03:00 |
|
Thales Macedo Garitezi
|
5df7314255
|
feat(kafka): ensure allocated resources are removed on failures
|
2023-05-25 16:38:09 -03:00 |
|
Zaiming (Stone) Shi
|
aaf3bf27c4
|
fix(kafka): ensure brod_gssapi sasl_auth are include in release
|
2023-05-07 09:43:58 +02:00 |
|
Andrew Mayorov
|
90cf1ade74
|
chore: bump application versions
* emqx_connector 0.1.22
* emqx_bridge_gcp_pubsub 0.1.1
* emqx_bridge_kafka 0.1.2
* emqx_bridge_pulsar 0.1.1
* emqx_ee_connector 0.1.12
|
2023-05-02 17:29:22 +03:00 |
|
Andrew Mayorov
|
4575167607
|
feat(resource): drop `manager_id()` type
|
2023-05-02 17:29:20 +03:00 |
|
Thales Macedo Garitezi
|
120d3e70ea
|
chore: bump app vsns
|
2023-04-24 10:28:26 -03:00 |
|
Thales Macedo Garitezi
|
4bcfbea056
|
refactor(kafka_consumer): follow up refactoring requested from previous pull request
Follow up from https://github.com/emqx/emqx/pull/10273
|
2023-04-24 09:28:36 -03:00 |
|
Stefan Strigler
|
9c11bfce80
|
refactor: rename emqx_misc to emqx_utils
|
2023-04-14 13:41:27 +02:00 |
|
Thales Macedo Garitezi
|
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 |