yuanbiao/emqx
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
11,786 Commits 393 Branches 684 Tags 74 MiB
a522e957e4
Commit Graph

11786 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
JimMoen
a522e957e4
Merge pull request #9034 from JimMoen/chore-bump-vsn-influxdb-cilent-erl 
chroe: bump `influxdb-client-erl` version
 2022-09-26 15:40:48 +08:00
JimMoen
9fbd7b6e17 chore: bump influxdb-client-erl version 2022-09-26 09:42:32 +08:00
Zaiming (Stone) Shi
f6ac4c3a76
Merge pull request #8798 from zmstone/0815-feat-add-kafka-connector 
feat: Add Kafka connector
 2022-09-24 22:57:50 +02:00
Kjell Winblad
5ec4b0a6ca fix: fix entrypoint in docker compose for Kafka bridge test 2022-09-23 15:58:22 +02:00
Kjell Winblad
ac37c5d58a test: github actions debug printouts 2022-09-23 15:02:01 +02:00
Kjell Winblad
a3c88b40a0 test: changes to make Kafka container run in GitHub action 2022-09-23 14:33:41 +02:00
Kjell Winblad
8e514680d8 test: fix bad binary pattern 2022-09-23 13:54:11 +02:00
Xinyu Liu
83a3d836b0
Merge pull request #9035 from terry-xiaoyu/review_changes 
fix(bridges): some issues found in code review
 2022-09-23 18:49:58 +08:00
Shawn
d24441b204 fix(bridges): some issues found in code review 2022-09-23 18:32:39 +08:00
Zaiming (Stone) Shi
7b601bf970 chore: delete bad parse_bridge function clause 2022-09-23 11:53:02 +02:00
Kjell Winblad
c4f7d385b5 test: fix true not allowed as docker compose env var value 2022-09-23 11:47:12 +02:00
Kjell Winblad
9f3e38aeb0 test: fix error in script detected by spellcheck script 2022-09-23 10:37:30 +02:00
Kjell Winblad
adc67b165b test: test cases for Kafka bridge REST API 2022-09-23 10:09:07 +02:00
Zaiming (Stone) Shi
516d60c7da build: fix deps consistency check 2022-09-23 09:00:17 +02:00
Zaiming (Stone) Shi
ba34326010 ci(kafka): fix shellcheck errors 2022-09-23 08:58:51 +02:00
zhouzb
f424c411ff
Merge pull request #9030 from tigercl/chore/bump-dashboard-vsn 
chore: update dashboard vsn
 2022-09-23 14:07:40 +08:00
zhouzb
48bb116905 chore: update dashboard vsn 2022-09-23 13:50:12 +08:00
JimMoen
6d37fc8dcb
Merge pull request #9012 from JimMoen/rm-influxdb-udp 
Hide influxdb udp bridge.
 2022-09-22 10:33:05 +08:00
Xinyu Liu
4c0a04f8d5
Merge pull request #9021 from terry-xiaoyu/async_batch_resume_from_queue 
refactor(resource): resume from queue/inflight-window with async-sending and batching
 2022-09-22 09:34:10 +08:00
Shawn
b325633390 refactor(resource): resume from queue/inflight-window with async-sending and batching 2022-09-21 22:58:47 +08:00
JianBo He
c0850be71e
Merge pull request #9013 from HJianBo/fix-mqtt-bridge 
chore: update emqtt to 1.7.0-rc.2
 2022-09-21 17:31:43 +08:00
JianBo He
89711881f5 chore: update emqtt to 1.7.0-rc.2 
To avoid the MQTT bridge blocked once the inflight window fulled
see: https://github.com/emqx/emqtt/pull/171
 2022-09-20 15:02:27 +08:00
JimMoen
6788881642 fix: hide influxdb udp config 2022-09-20 14:46:59 +08:00
JimMoen
03495d8d36 fix: influxdb server string support scheme prefix 2022-09-20 14:46:59 +08:00
Xinyu Liu
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
Shawn
9aa7e826cb refactor(resource): fast resume resource worker if inflight msgs are ACKed 2022-09-17 00:34:30 +08:00
Kjell Winblad
ac2922fc4c test: Kafka bridge cases for all combinations of SASL and SSL 2022-09-16 16:44:12 +02:00
Shawn
8307f04c2e refactor(resource): save inflight size into the ETS table 2022-09-16 16:52:08 +08:00
JimMoen
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
Kjell Winblad
be7a8c11a8 test: make bridge name unique in tests 2022-09-15 16:21:32 +02:00
Kjell Winblad
4dc26eeba7 fix: use different instance id in Kafka auth test 2022-09-15 07:33:07 +02:00
Xinyu Liu
7242ffd713
Merge pull request #8959 from terry-xiaoyu/fix_mqtt_bridge_hangs_on_msg_sending 
Fix mqtt bridge hangs on msg sending
 2022-09-15 12:26:12 +08:00
Shawn
d5d3972ff5 chore: add test cases for MQTT Bridge reconnecting 2022-09-15 10:19:33 +08:00
JimMoen
0390a5e547 fix(bridge): mysql bridge error case 2022-09-15 09:36:52 +08:00
JimMoen
54a9c8d201 chore: refine influxdb bridge description 2022-09-15 09:36:52 +08:00
Shawn
4e211c12d3 fix(mqtt_bridge): return value of sending messages was discarded 2022-09-15 08:57:01 +08:00
Kjell Winblad
5820b028cb feat: add test case for Kerberos Kafka authentication 2022-09-14 17:03:37 +02:00
Shawn
1c03c236f5 fix(mqtt_bridge): handle send_to_remote in idle state 2022-09-14 15:19:30 +08:00
Shawn
f41adb0997 refactor: change some default values of resource_opts 2022-09-14 15:18:07 +08:00
zhongwencool
b2732dc3ff
Merge pull request #8950 from zhongwencool/rename-emqx-enterprise.conf 
feat: don't include emqx-entriprise.conf in opensource
 2022-09-14 11:05:28 +08:00
Zhongwen Deng
499ed3ca51 chore: don't generate enterprise.conf when not emqx-enterprise profile 2022-09-14 10:13:58 +08:00
Zaiming (Stone) Shi
e45c99bf79 fix: kafka bridge schema 2022-09-13 20:02:48 +02:00
Kjell Winblad
f0e03086a6 test: add test cases for Kafka SASL auth mechanisms plain and scram 2022-09-13 19:46:56 +02:00
Zaiming (Stone) Shi
0c1595be02 feat: Add Kafka connector 2022-09-13 19:46:56 +02:00
Zaiming (Stone) Shi
477d4b0b03
Merge pull request #8947 from zmstone/0913-sync-master-to-ee50 
0913 sync master to ee50
 2022-09-13 15:46:52 +02:00
Zhongwen Deng
6a470dc3ac feat: don't include emqx-entriprise.conf in opensource 2022-09-13 18:53:56 +08:00
Zaiming (Stone) Shi
4534966e36 Merge remote-tracking branch 'origin/master' into dev/ee5.0 2022-09-13 12:16:54 +02:00
Zaiming (Stone) Shi
752eaeb899
Merge pull request #8944 from zmstone/0912-spellcheck-dict 
0912 spellcheck dict
 2022-09-13 12:15:09 +02:00
Xinyu Liu
fe445cd52d
Merge pull request #8946 from terry-xiaoyu/refactor_counters_resource 
refactor: rename some metrics for emqx_resource
 2022-09-13 15:51:14 +08:00
Zaiming (Stone) Shi
d4e8a5377c ci: run spellcheck 0.4.0 2022-09-13 09:45:37 +02:00