dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
12,131 Commits 106 Branches 71 Tags
Commit Graph

49 Commits

Author SHA1 Message Date
AndreMaz
198f3ca21d allow to configure kafkajs connectionTimeout 2023-01-25 11:06:23 +00:00
Sergey Matvienko
5776f5b39b js-executor - improved lifecycle events and added kill for crash event 2022-11-04 18:11:53 +02:00
ViacheslavKlimov
831332be7b Use hash of tenant id and body when resolving script for remote JS executor 2022-10-11 12:01:55 +03:00
Vladyslav_Prykhodko
60853dd5d6 Refactor JavaScript Executor AWS SQS queue 2022-07-08 15:25:00 +03:00
Vladyslav_Prykhodko
b4592f5f92 Fix incorrect start JavaScript Executor AWS SQS queue 2022-07-08 14:15:55 +03:00
Vladyslav_Prykhodko
bbfca14302 Fix incorrect shutdown JavaScript Executor RabbitMQ queue 2022-07-08 10:56:46 +03:00
Igor Kulikov
7019b98c00 JS executor code refactor 2022-07-07 19:37:36 +03:00
Vladyslav_Prykhodko
bbc43c2572 Graceful shutdown JavaScript Executor Microservice and minor change in logs 2022-07-07 17:15:59 +03:00
Vladyslav_Prykhodko
ed6e636918 Refactor JS-Executor microservice to typescript 2022-07-07 12:43:22 +03:00
Sergey Matvienko
b9a7d4a6d9 js-executor log cleanup 2022-07-06 19:08:06 +03:00
Sergey Matvienko
3e436ee866 js-executor: kafkaClient.producer({ createPartitioner: Partitioners.DefaultPartitioner }) as mentioned in migration notes for the major kafka.js 2.0 2022-06-21 18:48:14 +03:00
Vladyslav_Prykhodko
fbb90fe79a UI: Fixed vulnerabilities in tb-js-executor 2022-06-14 11:18:24 +03:00
Igor Kulikov
da4c742872 Update license year to 2022 2022-01-17 14:07:46 +02:00
Igor Kulikov
0d7adb73eb Improve js executor kafka consumer to exit application in case of not retryable error. 2021-09-02 10:34:28 +03:00
Sergey Matvienko
9a4a94621a js-executor: parameter added for Kafka PARTITIONS_CONSUMED_CONCURRENTLY to decrease max latency while scale down replicas 2021-06-10 14:47:41 +03:00
Kien Truong
3a31b9c5ea Fix wrong configuration key for Compression Type 
Fix #4678

(cherry picked from commit c176ca94aa0f612c3bb3856ae2acf3a399cc74a4)
 2021-06-10 14:47:19 +03:00
Vladyslav_Prykhodko
dd74824570 js-executor: Refactoring Kafka executor for use async/await 2021-06-09 13:30:28 +03:00
Vladyslav_Prykhodko
41391dbef8 js-executor: code format 2021-06-01 18:06:10 +03:00
Vladyslav_Prykhodko
1d9fc4a322 js-executor: typo fix 2021-06-01 18:01:21 +03:00
Sergey Matvienko
a4e28ad945 js-executor fixed promises for each message for Kafka batches 2021-06-01 17:15:34 +03:00
Sergey Matvienko
2cba1e2f16 js-executor reduced log severity to debug 2021-06-01 17:15:09 +03:00
Sergey Matvienko
93bea70205 js-executor: added parameters for producer TB_KAFKA_BATCH_SIZE and TB_KAFKA_LINGER_MS; added print stats frequency SCRIPT_STAT_PRINT_FREQUENCY 2021-06-01 17:15:00 +03:00
Sergey Matvienko
0970ce65b4 js-executor: maxBatchSize 2021-06-01 16:20:40 +03:00
Sergey Matvienko
35e2ff99c3 js-executor: send messages as batch 2021-06-01 16:20:35 +03:00
Sergey Matvienko
d729d9ee95 js-executor: instrumentation event for producer and consumer to define the exact flow how to Kafka works without batches (for debug only) 2021-06-01 16:20:31 +03:00
Sergey Matvienko
c08e2ada1f remote js-executor: parameter added KAFKA_CLIENT_ID 2021-04-23 15:04:00 +03:00
Sergey Matvienko
01bf53b7f5 remote js-executor: parameter added TB_QUEUE_KAFKA_REQUEST_TIMEOUT_MS 2021-04-23 15:04:00 +03:00
Sergey Matvienko
3236d3ce9e remote js-executor: producer compression: CompressionTypes.GZIP 2021-04-23 15:04:00 +03:00
Sergey Matvienko
c94dc5972e remote js-executor: parameter added TB_KAFKA_ACKS="1" 2021-04-23 15:04:00 +03:00
Sergey Matvienko
c9f3562b58 remote js-executor: parameter added KAFKA_CLIENT_ID 2021-04-23 15:04:00 +03:00
Igor Kulikov
d31358b2ea Update license header - set 2021 year 2021-01-11 13:42:16 +02:00
YevhenBondarenko
eeec6bac9f sqs producer improvements 2020-11-04 17:59:42 +02:00
YevhenBondarenko
9d82899f04 raised kafkajs version and improvements kafkaTemplate.js 2020-09-28 11:45:24 +03:00
YevhenBondarenko
f16672cbf6 added partition property for kafka 2020-09-02 18:14:23 +03:00
Yevhen Bondarenko
e318b193bd
Develop/2.5.3 confluent cloud (#3259) 
* added other parameters for queue kafka

* Added support Confluent Cloud

* fix js executor kafka connection

* refactored
 2020-08-11 11:15:41 +03:00
Yevhen Bondarenko
7ee2cdfe3e
Fixes and refactoring (#2761) 
* fix sqs js executor and refactored RemoteJsInvokeService

* added REMOTE_JS_MAX_REQUEST_TIMEOUT=20000 for aws-sqs, pubsub, service-bus docker environments

* added REMOTE_JS_MAX_REQUEST_TIMEOUT=20000 for aws-sqs, pubsub, service-bus docker environments

* refactored

* docker-compose.pubsub.yml improvements

* rabbitmq js executor improvements
 2020-05-13 14:08:54 +03:00
YevhenBondarenko
00e32ee8a3 merge with feature/queue-consumers-refactoring 2020-05-04 09:39:04 +03:00
YevhenBondarenko
06c3caf082 refactored 2020-05-02 13:34:11 +03:00
YevhenBondarenko
eedb383845 AWS improvements 2020-05-01 14:15:31 +03:00
YevhenBondarenko
e5c5aa705f refactored 2020-04-30 20:14:34 +03:00
YevhenBondarenko
237c288050 Merge branch 'master' of https://github.com/thingsboard/thingsboard into develop/2.5-js-executor 2020-04-30 16:24:28 +03:00
YevhenBondarenko
9ef3445b77 refactored 2020-04-30 16:24:12 +03:00
Andrii Shvaika
30a2d19d2d Fixes to Kafka JS headers issue 2020-04-30 15:17:39 +03:00
Yevhen Bondarenko
1599b24c3a
Develop/2.5 js executor (#2685) 
* moved kafka from service.js to own module

* created awsSqs, pubSub, rabbitmq js-executors

* revert RemoteJsInvokeService

* revert thingsboard.yml

* added queue settings to js-executor

* refactored queue factories

* added queue params to pubsub js-executor

* azure service bus js-executor
 2020-04-29 21:02:47 +03:00
YevhenBondarenko
43b2eedbd5 azure service bus js-executor 2020-04-29 18:27:53 +03:00
YevhenBondarenko
8c413f8b9c added queue params to pubsub js-executor 2020-04-29 10:42:18 +03:00
YevhenBondarenko
ef35ee8c30 added queue settings to js-executor 2020-04-29 09:41:21 +03:00
YevhenBondarenko
0dc31fbdde created awsSqs, pubSub, rabbitmq js-executors 2020-04-28 16:13:16 +03:00
YevhenBondarenko
4fb309c37e moved kafka from service.js to own module 2020-04-21 13:30:11 +03:00