d117cec09e
js-executor: partitions_consumed_concurrently marked as experimental
5 years ago
c07379812b
js-executor: updated yarn.lock
5 years ago
cda6f3678b
js-executor: fixed license header
5 years ago
9ffa50f4a5
js-executor: fixed env variables mapping
5 years ago
9a4a94621a
js-executor: parameter added for Kafka PARTITIONS_CONSUMED_CONCURRENTLY to decrease max latency while scale down replicas
5 years ago
3a31b9c5ea
Fix wrong configuration key for Compression Type
Fix #4678
(cherry picked from commit c176ca94aa
5 years ago
05df5e03ef
Revert "js-executor: upgraded libraries to fix vulnerability warning (@google-cloud/pubsub", amqplib)"
Untested version with breaking changes declared
This reverts commit 80f83a86
5 years ago
98bea8eaf5
js-executor: http livenessProbe added
5 years ago
a7a7dca3b3
js-executor: upgraded libraries to fix vulnerability warning (@google-cloud/pubsub", amqplib)
5 years ago
dd74824570
js-executor: Refactoring Kafka executor for use async/await
5 years ago
c176ca94aa
Fix wrong configuration key for Compression Type
Fix #4678
5 years ago
ff7fa6237f
js-executor: zero check and code cleanup
5 years ago
ab5f1b5b63
js-executor: ScriptMap optimize work
5 years ago
41391dbef8
js-executor: code format
5 years ago
1d9fc4a322
js-executor: typo fix
5 years ago
a4e28ad945
js-executor fixed promises for each message for Kafka batches
5 years ago
2cba1e2f16
js-executor reduced log severity to debug
5 years ago
93bea70205
js-executor: added parameters for producer TB_KAFKA_BATCH_SIZE and TB_KAFKA_LINGER_MS; added print stats frequency SCRIPT_STAT_PRINT_FREQUENCY
5 years ago
0970ce65b4
js-executor: maxBatchSize
5 years ago
35e2ff99c3
js-executor: send messages as batch
5 years ago
d729d9ee95
js-executor: instrumentation event for producer and consumer to define the exact flow how to Kafka works without batches (for debug only)
5 years ago
0c88665654
js-executor: scriptMap refactored from Object to the Map()
5 years ago
b9c73a283c
Update msa readme
5 years ago
42438e4c95
Configure Docker setup for SNMP transport
5 years ago
18f27b18fe
remote js-executor: adjusted default values
5 years ago
c08e2ada1f
remote js-executor: parameter added KAFKA_CLIENT_ID
5 years ago
01bf53b7f5
remote js-executor: parameter added TB_QUEUE_KAFKA_REQUEST_TIMEOUT_MS
5 years ago
3236d3ce9e
remote js-executor: producer compression: CompressionTypes.GZIP
5 years ago
c94dc5972e
remote js-executor: parameter added TB_KAFKA_ACKS="1"
5 years ago
a569058c29
remote js-executor: added metric response sent to queue ms in debug level; parameter added SLOW_QUERY_LOG_BODY="true" to enable log bloat
5 years ago
c9f3562b58
remote js-executor: parameter added KAFKA_CLIENT_ID
5 years ago
d25d13d7c0
remote js-executor: added slow query log, log config on service start
5 years ago
ae5632f8ab
Fix docker images. Upgrade docker postgres to version 12.
5 years ago
4a63660e1d
Version set to 3.3.0-SNAPSHOT
5 years ago
8f2438d6ab
SNMP devices balancing ( #4254 )
* Fix merge errors
* Implement SNMP transports balancing
* Refactor; implement transport device cache
* Refactor
* Finish up device lifecycle handling implementing; refactor
* Refactor
* Change base image to thingsboard/openjdk11 for msa snmp transport
* Refactor
* Change transport services names to upper-case
5 years ago
ae4de0c3d1
updated httpclient, spring-boot, netty versions
5 years ago
37b88908fd
Fix merge errors
5 years ago
5a72479951
[WIP] SNMP initial implementation ( #3755 )
* Add SNMP type to transport profiles
* Update reference config for transport profiles
* Initial implementation to retrieve a value using SNMP GET message
* Fix license header
* Move config files
* Use async handler for SNMP response
* Send SNMP agent response to attributes and telemetry
* UI: add SNMP option for device profile
* UI: use JSON field to set SNMP profile configuration
* Handle device profile update event
* Use concurrent hash map for SNMP device sessions
* UI: Add device transport configuration control
* Cancel async request to avoid memory leak and timeout handling
* Start SNMP pooling after application started
* Move OID per profile mapping to SNMP transport context
* Fix build after merge with 3.2.1-SNAPSHOT
* Init device sessions on TB start
* Fix build error, refactoring
* Update session context on device update
* Set device info on session context creating
* Refresh pooling params on device or profile update
* Update license header
* Process device and profile transport config update
* Process SNMP response asynchronously
* Change polling implementation
5 years ago
8fe6c956c8
Version set to 3.3.0-SNAPSHOT. Code style improvements.
5 years ago
50d96fb49e
Version set to 3.3.0-SNAPSHOT
5 years ago
3255eb9027
Version set to 3.2.2-SNAPSHOT
5 years ago
3c52c8c221
added "min.insync.replicas" parameter to the kafka topics
5 years ago
59a54211f9
Fix compile errors and warnings.
5 years ago
58e2affa2c
Use compatible with JDK 11 Cassandra ver. 4.0
5 years ago
51794534f8
Update deb/rpm packages java dep versions. Update JVM options.
5 years ago
b6299623fe
Fix postgresql distribution config in docker files
5 years ago
3f83be21da
Fix lombok config. Update base openjdk image
5 years ago
22e5771120
JDK 11 Support
5 years ago
2b47fe9202
Updated license header
5 years ago
61723da391
Version set to 3.3.0-SNAPSHOT
5 years ago
Sergey Matvienko
Kien Truong
Vladyslav_Prykhodko
Igor Kulikov
Viacheslav Klimov
YevhenBondarenko
vkukhtyn