Andrii Shvaika
|
5a2bc396f2
|
Merge with hotfix/3.6
|
2023-10-25 15:43:12 +03:00 |
|
dashevchenko
|
15e6190a9d
|
optimized topicName creation in HashPartitionService
|
2023-10-23 17:40:39 +03:00 |
|
dashevchenko
|
603be29f1b
|
fixed topic naming
|
2023-10-23 12:35:38 +03:00 |
|
dashevchenko
|
f3a0d3a7e8
|
fixed HashPartitionService
|
2023-10-23 11:54:45 +03:00 |
|
ViacheslavKlimov
|
be7854fb5b
|
Add 'isolated' to topic and consumer group name for isolated queues
|
2023-10-19 18:58:41 +03:00 |
|
ViacheslavKlimov
|
cf951ee2b2
|
Multiple improvements for Rule Engine consumer services
|
2023-10-19 11:09:34 +03:00 |
|
Andrii Shvaika
|
45fd970898
|
Refactoring in progress
|
2023-10-19 11:09:11 +03:00 |
|
dashevchenko
|
dd53193371
|
fixed unit tests
|
2023-10-18 11:43:21 +03:00 |
|
Dmytro Skarzhynets
|
24dda7a3ea
|
Merge with master
|
2023-10-18 08:33:31 +03:00 |
|
dashevchenko
|
c195fd5a4c
|
added ability to add global prefix for all topics
|
2023-10-17 19:44:50 +03:00 |
|
Andrii Shvaika
|
7b0a3c282c
|
Merge with hotfix branch
|
2023-10-16 17:43:01 +03:00 |
|
Sergey Matvienko
|
febff6bd00
|
TbKafkaProducerTemplate: addAnalyticHeaders - stacktrace level increased from 10 to 20 for TRACE enabled
|
2023-10-16 13:46:37 +02:00 |
|
Andrii Shvaika
|
e768afc948
|
Merge 3.6 -> 3.7
|
2023-09-28 12:20:06 +03:00 |
|
Andrii Shvaika
|
dd4b874b5f
|
Version set to 3.6.1-SNAPSHOT
|
2023-09-27 17:38:27 +03:00 |
|
Igor Kulikov
|
8cefca23ac
|
Version set to 3.6.1-SNAPSHOT
|
2023-09-25 11:27:00 +03:00 |
|
Dmytro Skarzhynets
|
0d7886d6e1
|
Merge branch 'develop/3.6' into feature/device-state-node
|
2023-09-20 14:38:40 +03:00 |
|
Dmytro Skarzhynets
|
28879cb73b
|
Add review fixes
|
2023-09-19 14:02:23 +03:00 |
|
ViacheslavKlimov
|
4e526aa969
|
Queue removal: always publish PartitionChangeEvent; remove redundant recalculatePartitions; add debug log
|
2023-09-14 16:27:44 +03:00 |
|
ViacheslavKlimov
|
0d8a2549d9
|
Single PartitionChangeEvent after recalculatePartitions
|
2023-09-14 15:22:53 +03:00 |
|
ViacheslavKlimov
|
3f2a3e35ff
|
Fixes for partition recalculation with isolated queues
|
2023-09-13 17:37:19 +03:00 |
|
ShvaykaD
|
0489e94c1d
|
Merge remote-tracking branch 'upstream/develop/3.6' into feature/rpc-sequential-strategies
|
2023-09-06 14:43:21 +03:00 |
|
Igor Kulikov
|
98c245e293
|
Switch to version 3.6.0
|
2023-09-05 18:28:15 +03:00 |
|
Andrii Shvaika
|
ca6095402f
|
Merge with master
|
2023-08-17 12:19:02 +03:00 |
|
ViacheslavKlimov
|
d30f8a8352
|
Minor refactoring
|
2023-08-16 17:53:44 +03:00 |
|
ViacheslavKlimov
|
b8a7c6a3cd
|
Don't init unneeded actors and consumers for dedicated Rule Engine
|
2023-08-15 16:40:26 +03:00 |
|
Andrii Shvaika
|
344ffb2e0b
|
Merge with master
|
2023-08-14 15:02:17 +03:00 |
|
ViacheslavKlimov
|
6751820e0a
|
Dedicated Rule Engines for tenant profile
|
2023-08-14 12:57:53 +03:00 |
|
ViacheslavKlimov
|
ae76f4ebbb
|
Merge branch 'master' into feature/update-tenant-profile-isolation
|
2023-08-11 13:39:03 +03:00 |
|
ViacheslavKlimov
|
f32e2f6fde
|
Refactoring after review
|
2023-08-10 12:03:15 +03:00 |
|
YevhenBondarenko
|
141a7ff0e6
|
changed recalculate_delay
|
2023-08-09 21:21:15 +02:00 |
|
ViacheslavKlimov
|
0f13d46144
|
Add more tests
|
2023-08-03 13:54:59 +03:00 |
|
ShvaykaD
|
c2ce40cd39
|
added rpc sequential strategies: init commit
|
2023-08-02 16:05:18 +03:00 |
|
ViacheslavKlimov
|
c087359077
|
Move messages to other queue on deletion; improvements
|
2023-08-01 13:57:32 +03:00 |
|
Andrew Shvayka
|
f618599d15
|
Merge pull request #8998 from smatvienko-tb/feature/kafka-producer-append-debug-headers
TbKafkaProducerTemplate will add analytics headers for each message on debug or trace log level
|
2023-07-31 17:26:01 +03:00 |
|
Andrew Shvayka
|
a8d0968cc3
|
Merge pull request #8983 from smatvienko-tb/feature/onRateLimit-TbMsgPackCallback-skipAllRateLimited
Rule engine: ack all rate limited failures
|
2023-07-31 17:17:36 +03:00 |
|
YevhenBondarenko
|
ac2aac8aa7
|
refactored due to comments
|
2023-07-31 13:51:03 +03:00 |
|
YevhenBondarenko
|
948f517898
|
added zk restart node tests
|
2023-07-31 13:50:57 +03:00 |
|
YevhenBondarenko
|
ce9552e1a8
|
improvements
|
2023-07-31 13:50:49 +03:00 |
|
YevhenBondarenko
|
68149d9673
|
added recalculetePartitions delay for node restart
|
2023-07-31 13:50:41 +03:00 |
|
YevhenBondarenko
|
d9c39c362e
|
refactored due to comments
|
2023-07-28 14:20:33 +02:00 |
|
ViacheslavKlimov
|
5862b417aa
|
Add custom topic properties configuration
|
2023-07-28 12:06:04 +03:00 |
|
Sergey Matvienko
|
825eaf640c
|
RuleEngineException cause added to be able to analyse cause by rate limit exceptions
|
2023-07-27 21:38:02 +02:00 |
|
Sergey Matvienko
|
2cccd0951a
|
TbKafkaProducerTemplate: addAnalyticHeaders optimized
|
2023-07-27 19:43:06 +02:00 |
|
ViacheslavKlimov
|
137cc18099
|
Auto offset reset config for Kafka
|
2023-07-27 19:58:31 +03:00 |
|
ViacheslavKlimov
|
55775f2815
|
Consumer group per isolated tenant's queue; remove sleeping for Kafka consumer
|
2023-07-27 18:33:03 +03:00 |
|
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
|
2023-07-26 20:45:42 +02:00 |
|
ViacheslavKlimov
|
6db3171ffb
|
Refactoring
|
2023-07-25 16:16:48 +03:00 |
|
ViacheslavKlimov
|
fa61783ac6
|
Log topics list on unsubscribe
|
2023-07-25 15:44:25 +03:00 |
|
ViacheslavKlimov
|
3b86c8c1f5
|
Refactor HashPartitionService.resolve(..)
|
2023-07-25 15:44:25 +03:00 |
|
ViacheslavKlimov
|
1ee3c24532
|
Refactor HashPartitionService.resolve(..)
|
2023-07-25 15:44:25 +03:00 |
|