yanzhiemq
|
557689974f
|
ci: run scheduled packages build of release-56
|
2024-03-04 09:11:11 +08:00 |
|
Zaiming (Stone) Shi
|
e9a5670cce
|
Merge pull request #12581 from zmstone/0223-add-json-schema
feat: schema registry supports json schema
|
2024-03-02 10:09:31 +01:00 |
|
Zaiming (Stone) Shi
|
fa275bf0a2
|
refactor(schema_registry): use one func for both encode and decode check
|
2024-03-01 07:20:59 +01:00 |
|
zhongwencool
|
d56fb22208
|
Merge pull request #12595 from thalesmg/kafka-consumer-source-m-20240223
feat: migrate kafka consumer bridge to source + connector
|
2024-03-01 10:11:16 +08:00 |
|
Zaiming (Stone) Shi
|
5df1784b49
|
docs: add changelog for PR 12581 (JSON schema)
|
2024-02-29 21:07:56 +01:00 |
|
Zaiming (Stone) Shi
|
b7e5ea2941
|
feat(schema_registry): add JSON schema
|
2024-02-29 21:03:52 +01:00 |
|
Thales Macedo Garitezi
|
5d94a910b9
|
test: reduce flakiness
|
2024-02-29 13:59:43 -03:00 |
|
Zaiming (Stone) Shi
|
21cf600242
|
chore: address previous review comments
|
2024-02-29 16:13:52 +01:00 |
|
Zaiming (Stone) Shi
|
66fbcdcefa
|
test: fix a compile warning
|
2024-02-29 16:13:52 +01:00 |
|
Zaiming (Stone) Shi
|
5afe000ada
|
Merge pull request #12612 from zmstone/0226-fix-schema-registry-replication
refactor: change schema registry SERD_TAB to ets
|
2024-02-29 14:58:41 +01:00 |
|
Ilya Averyanov
|
5bb769e659
|
Merge pull request #12616 from savonarola/0229-ds-interface
feat(ds): export types
|
2024-02-29 15:42:42 +02:00 |
|
Thales Macedo Garitezi
|
16b3dc1166
|
refactor: use individual keys for subscriber id resources
|
2024-02-29 10:39:37 -03:00 |
|
zhongwencool
|
bc9de20024
|
Merge pull request #12540 from zhongwencool/bridge-pulsar-v2
feat: pulsar bridge v2
|
2024-02-29 21:25:11 +08:00 |
|
Thales Macedo Garitezi
|
0aa9a872a3
|
feat: check `brod_sup` for client id
|
2024-02-29 09:53:23 -03:00 |
|
William Yang
|
b82973b36b
|
Merge pull request #11868 from qzhuyan/fix/william/takeover-pub-willmsg
fix: willmsg not published in takeover
|
2024-02-29 13:14:18 +01:00 |
|
Ilya Averyanov
|
b706caf294
|
feat(ds): export types
|
2024-02-29 14:27:18 +03:00 |
|
Ilya Averyanov
|
f87c17b540
|
Merge pull request #12611 from savonarola/0228-ds-interface
feat(ds): update delete/count interface
|
2024-02-29 10:31:51 +02:00 |
|
Ilya Averyanov
|
d4519bda82
|
Merge pull request #12589 from savonarola/0222-retainer-interface
Make retainer pluggable
|
2024-02-29 10:31:15 +02:00 |
|
zhongwencool
|
3814203fa2
|
test(pulsar): add pulsar action v2 testcase
|
2024-02-29 16:23:37 +08:00 |
|
zhongwencool
|
e9e1daf962
|
chore: update some pulsar's desc
|
2024-02-29 16:23:37 +08:00 |
|
zhongwencool
|
650f9659a4
|
fix: create pulsar producer when on_add_channel
|
2024-02-29 16:23:37 +08:00 |
|
zhongwencool
|
7f1b4cef27
|
feat: pulsar bridge v2
|
2024-02-29 16:23:37 +08:00 |
|
zhongwencool
|
21e0ecfcce
|
Merge pull request #12583 from zhongwencool/wait-for-listener-stop
chore: wait_for cowboy listener release sock when stop_listener
|
2024-02-29 15:03:22 +08:00 |
|
lafirest
|
d2dda2535b
|
Merge pull request #12602 from lafirest/fix/iotdb_ping
fix(iotdb): use the `ping` API to check the status of the IOTDB connections
|
2024-02-29 12:26:10 +08:00 |
|
firest
|
0bebd66f05
|
fix(iotdb): make dialyzer happy
|
2024-02-29 10:51:12 +08:00 |
|
zhongwencool
|
49b508544e
|
chore: port not released msg
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
|
2024-02-29 10:49:29 +08:00 |
|
Zaiming (Stone) Shi
|
10c1245125
|
refactor: change schema registry SERD_TAB to ets
Prior to this change, it's a mria/mnesia table
which may cause nodes to overwrite each other.
|
2024-02-28 23:13:07 +01:00 |
|
Ilya Averyanov
|
d5ae0e5c53
|
feat(ds): update delete/count interface
|
2024-02-28 22:51:24 +03:00 |
|
Zaiming (Stone) Shi
|
704eceb7c7
|
Merge pull request #12599 from zmstone/0227-refactor-log-config-template
docs: add log docs
|
2024-02-28 17:58:14 +01:00 |
|
Andrew Mayorov
|
ef4ae92da4
|
Merge pull request #12523 from keynslug/ft/bump-ekka-0.19.0
refactor: bump ekka to 0.19.0 w/o mnesia boot phase
|
2024-02-28 17:46:29 +01:00 |
|
Ilya Averyanov
|
dfdf7455d3
|
feat(retainer): make additional implementations pluggable
Co-authored-by: Thales Macedo Garitezi <thalesmg@gmail.com>
|
2024-02-28 18:43:17 +03:00 |
|
Ilya Averyanov
|
d94066a10a
|
chore(retainer): refactor types; remove hotwiring to builtin config
|
2024-02-28 18:43:16 +03:00 |
|
Ilya Averyanov
|
aa2ee9c409
|
chore(retainer): add backend creation to the behaviour
|
2024-02-28 18:43:16 +03:00 |
|
Andrew Mayorov
|
20c4029b33
|
test(cluster-rpc): unload any mocks in `end_per_suite/1`
Co-authored-by: Thales Macedo Garitezi <thalesmg@gmail.com>
|
2024-02-28 14:52:37 +01:00 |
|
Andrew Mayorov
|
bad79965c0
|
Merge pull request #12490 from keynslug/fix/mgmt-api-topics-fullscan
fix(api-topics): avoid doing full scans over router tables
|
2024-02-28 14:04:35 +01:00 |
|
Andrew Mayorov
|
c3b044a37b
|
fix(api-topics): respond with `count` when it's cheap to compute
|
2024-02-28 11:28:33 +01:00 |
|
Andrew Mayorov
|
bd578a799e
|
fix(api-topics): avoid doing full scans over router tables
|
2024-02-28 10:52:44 +01:00 |
|
Andrew Mayorov
|
9bb0868628
|
test(api-topics): add testcase verifying paged queries work
|
2024-02-28 10:52:41 +01:00 |
|
zhongwencool
|
660a1ce99d
|
chore: use gen_tcp:recv timeout to wait socket closed
|
2024-02-28 16:18:32 +08:00 |
|
zhongwencool
|
4307aecefd
|
chore: wait_for cowboy listener release sock when stop_listener
|
2024-02-28 14:24:15 +08:00 |
|
firest
|
c3a2cf6220
|
chore: update change && bump version
|
2024-02-28 13:18:48 +08:00 |
|
zhongwencool
|
04af31df13
|
Merge pull request #12605 from zhongwencool/hstream-fix
fix: get grpc_timeout from hstreamdb connector config failed
|
2024-02-28 09:34:17 +08:00 |
|
zhongwencool
|
aa7def425d
|
fix: get grpc_timeout from hstreamdb connector config failed
|
2024-02-28 08:45:06 +08:00 |
|
Andrew Mayorov
|
28d664bae2
|
test(pulsar): simplify the test suite
|
2024-02-27 23:51:54 +01:00 |
|
Andrew Mayorov
|
367ffa8e80
|
feat(utils-fs): add function to compute relpaths naively
|
2024-02-27 23:41:50 +01:00 |
|
Thales Macedo Garitezi
|
6b9844ae82
|
feat: migrate kafka consumer bridge to source + connector
Fixes https://emqx.atlassian.net/browse/EMQX-11848
|
2024-02-27 17:52:33 -03:00 |
|
Thales Macedo Garitezi
|
787dcd0e86
|
Merge pull request #12577 from thalesmg/gcp-service-json-binary-m-20240223
feat(gcp_pubsub_bridges): make service account json a binary
|
2024-02-27 15:42:42 -03:00 |
|
Zaiming (Stone) Shi
|
ef99037335
|
docs: add log docs
|
2024-02-27 19:24:56 +01:00 |
|
Andrew Mayorov
|
6ea9d2a6d9
|
test(conf): simplify confsync test suite
|
2024-02-27 16:41:54 +01:00 |
|
Andrew Mayorov
|
ae79516fd2
|
test(cluster-rpc): ensure testsuite is side-effects-free
|
2024-02-27 16:41:54 +01:00 |