YevhenBondarenko
8ac80476ad
added encode/decode time stats and refactoring
3 years ago
YevhenBondarenko
d6b56177a2
fst stats in Grafana
3 years ago
dashevchenko
fa12ba544d
moved pubsub queue executor to PubSubSettings
3 years ago
dashevchenko
66b768a499
added @Lazy to PubSubRuleNodeExecutorProvider
3 years ago
dashevchenko
fbec7aab25
moved pubsub executors to pubsubSettings
3 years ago
dashevchenko
1be39aa9aa
fixed license, env name refactoring
3 years ago
dashevchenko
08727b4c36
added executor provider for pubsub queue, added env variable to manage pubsub queue executor provider thread pool
3 years ago
dashevchenko
4f22ef9733
created PubSubExecutor to use each time publisher is created and do not produce too much threads created
3 years ago
Andrii Shvaika
df24c363ce
Version set to 3.6.2-SNAPSHOT
3 years ago
dashevchenko
442fe9029e
added env variable to regulate pubsud queue executor threads pool size
3 years ago
dashevchenko
86f8965eab
fixed thingsboard.yml
3 years ago
ViacheslavKlimov
0812149524
Minor refactoring for HashPartitionService
3 years ago
ViacheslavKlimov
9e408cd6f3
Distribute partitions between Rule Engines based only on tenant id
3 years ago
Andrii Shvaika
694b6bf851
Refactoring: new data structures and message flow
Local Subscription Service refactoring
Refactoring of the proto structures
Bug fixing after refactoring
Minor improvements and bug fixes
Improvements to avoid additional DB calls
Bug fixes after refactoring
Cluster mode improvements
3 years ago
dashevchenko
15e6190a9d
optimized topicName creation in HashPartitionService
3 years ago
dashevchenko
603be29f1b
fixed topic naming
3 years ago
dashevchenko
f3a0d3a7e8
fixed HashPartitionService
3 years ago
ViacheslavKlimov
be7854fb5b
Add 'isolated' to topic and consumer group name for isolated queues
3 years ago
ViacheslavKlimov
cf951ee2b2
Multiple improvements for Rule Engine consumer services
3 years ago
Andrii Shvaika
45fd970898
Refactoring in progress
3 years ago
dashevchenko
dd53193371
fixed unit tests
3 years ago
dashevchenko
c195fd5a4c
added ability to add global prefix for all topics
3 years ago
Sergey Matvienko
febff6bd00
TbKafkaProducerTemplate: addAnalyticHeaders - stacktrace level increased from 10 to 20 for TRACE enabled
3 years ago
Igor Kulikov
8cefca23ac
Version set to 3.6.1-SNAPSHOT
3 years ago
ViacheslavKlimov
4e526aa969
Queue removal: always publish PartitionChangeEvent; remove redundant recalculatePartitions; add debug log
3 years ago
ViacheslavKlimov
0d8a2549d9
Single PartitionChangeEvent after recalculatePartitions
3 years ago
ViacheslavKlimov
3f2a3e35ff
Fixes for partition recalculation with isolated queues
3 years ago
Igor Kulikov
98c245e293
Switch to version 3.6.0
3 years ago
ViacheslavKlimov
d30f8a8352
Minor refactoring
3 years ago
ViacheslavKlimov
b8a7c6a3cd
Don't init unneeded actors and consumers for dedicated Rule Engine
3 years ago
ViacheslavKlimov
6751820e0a
Dedicated Rule Engines for tenant profile
3 years ago
ViacheslavKlimov
f32e2f6fde
Refactoring after review
3 years ago
YevhenBondarenko
141a7ff0e6
changed recalculate_delay
3 years ago
ViacheslavKlimov
0f13d46144
Add more tests
3 years ago
ShvaykaD
c2ce40cd39
added rpc sequential strategies: init commit
3 years ago
ViacheslavKlimov
c087359077
Move messages to other queue on deletion; improvements
3 years ago
YevhenBondarenko
ac2aac8aa7
refactored due to comments
3 years ago
YevhenBondarenko
948f517898
added zk restart node tests
3 years ago
YevhenBondarenko
ce9552e1a8
improvements
3 years ago
YevhenBondarenko
68149d9673
added recalculetePartitions delay for node restart
3 years ago
YevhenBondarenko
d9c39c362e
refactored due to comments
3 years ago
ViacheslavKlimov
5862b417aa
Add custom topic properties configuration
3 years ago
Sergey Matvienko
825eaf640c
RuleEngineException cause added to be able to analyse cause by rate limit exceptions
3 years ago
Sergey Matvienko
2cccd0951a
TbKafkaProducerTemplate: addAnalyticHeaders optimized
3 years ago
ViacheslavKlimov
137cc18099
Auto offset reset config for Kafka
3 years ago
ViacheslavKlimov
55775f2815
Consumer group per isolated tenant's queue; remove sleeping for Kafka consumer
3 years ago
Sergey Matvienko
c3e9ab5991
TbKafkaProducerTemplate will add headers for each message when log level: DEBUG - producerId and thread name; TRACE - stacktrace first 10-2=8 lines
3 years ago
ViacheslavKlimov
6db3171ffb
Refactoring
3 years ago
ViacheslavKlimov
fa61783ac6
Log topics list on unsubscribe
3 years ago
ViacheslavKlimov
3b86c8c1f5
Refactor HashPartitionService.resolve(..)
3 years ago