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

56 Commits

Author SHA1 Message Date
Vladyslav_Prykhodko
5c6b4122d3 Add SSL support for Kafka queue connection in JS executor 2024-05-16 18:02:23 +03:00
Alexander Keidel
005d555bc5 Global Queue Prefix is now correctly respected by js-executor, rule-node and tb-rule-engine-notifications-node- consumer groups 2024-02-14 13:25:13 +02:00
Igor Kulikov
c5a72ed8df Update license header to 2024 year. 2024-01-09 10:46:16 +02:00
dashevchenko
c8b8fb2147 added global queue prefix support for js-executor 2023-10-30 16:17:12 +02:00
Andrew Shvayka
27ae2fb119
Merge pull request #7991 from AndreMaz/feature/kafka_connection_timeout 
Allow to configure kafkajs `connectionTimeout` property
 2023-04-10 15:22:01 +03:00
Igor Kulikov
cbdc4517e4 Update license header year to 2023 2023-01-31 10:43:56 +02:00
AndreMaz
6a986b17f9 fix name of the var 2023-01-25 11:14:10 +00:00
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