5dff454038
fix(queue): prevent consumer busy-wait when partition assignment is empty
AbstractTbQueueConsumerTemplate.poll() returned emptyList() immediately
when partitions was empty, bypassing both doPoll() and the secondary
sleep guard (which is also skipped for backends that report
isLongPollingSupported()==true, e.g. Kafka). The result was a
permanent CPU-burning loop on consumers whose partition assignment
ended up empty after a rebalance cascade — observed on 26
ie-downlink-consumer threads (~244% total CPU) until container restart.
Route the empty-partition path through sleepAndReturnEmpty() so the
caller honors durationInMillis regardless of long-polling support.
1 month ago
25d3394e9f
Fix race condition in notification deduplication check
The alreadyProcessed() method used separate get() and put() calls on the
local cache, allowing concurrent threads in the notification executor pool
to both read null and bypass deduplication, creating duplicate notifications.
Replace with a single compute() call that atomically checks and updates
the cache entry, preventing the race between concurrent trigger processing.
Also fix: discard external cache timestamps that are more than 1 hour in
the future (clock skew protection), and avoid reading back from the SOFT
ref local cache when writing to external cache (GC could null it out).
2 months ago
c1044a989e
Introduce urgent API usage keys for quicker usage state update
4 months ago
5b5b4dff6b
Update license header
5 months ago
1044aabce3
Fix Kafka topics cache
6 months ago
0b305e6f2a
Alarm rules CF: real-time duration condition checks
8 months ago
f416e4677b
Refactoring for KafkaAdmin
10 months ago
e7580f6093
Short-lived cache for Kafka topics
10 months ago
1097005178
Refactor Kafka admin usage
10 months ago
01e72f4e30
Fix topics creation for isolated tenants
10 months ago
320e0b674e
Added per-edge stats ( #13651 )
10 months ago
b7f3c9fb63
Make component annotations inheritable
11 months ago
a3a5fd3180
Small refactoring of sendErrorResponse
11 months ago
a843c86227
EDQS: human readable response on failed to send kafka msg
12 months ago
d4c83b7fc3
Improve notification processing strategy. Fix tests
1 year ago
957965b351
Improvements for task processing
1 year ago
eaa0073003
Cancel currently running tasks when the job is discarded
1 year ago
069f052122
Refactoring and improvements for EDQS
1 year ago
506f48a89d
Moved TbServiceInfoProvider interface to separate module
1 year ago
8af37beb4a
New Cassandra rate limits: separated for Read and Write + Core and Rule Engine
1 year ago
5e46608abc
Support for job manager on Rule Engine
1 year ago
0dde966082
Support reprocessing for job with general error; job deletion; refactoring
1 year ago
95d1b5ebd7
Minor refactoring for TopicPartitionInfo
1 year ago
ef65dd9026
Fix missing queue prefixes
1 year ago
4fbb6c2e71
Jobs: refactoring
1 year ago
7d0b6bfdec
Refactoring for tasks api
1 year ago
14f24d2497
Fix readiness status for local EDQS
1 year ago
b97c1888f1
EDQS readiness check; refactor API enabling
1 year ago
8c959232d4
Configurable tasks poll interval; task processing timing
1 year ago
f5e816923d
Tasks partitioning strategies; jobs filter; fixes
1 year ago
1e5b6cc9a9
Remove task.getKey()
1 year ago
5993b8b963
Minor refactoring
1 year ago
ac9e738018
Task processing timeout
1 year ago
4c01b3d70a
Refactoring for task processor queue factories
1 year ago
e59460b42b
Task processors partitioning
1 year ago
950d1d85c4
Task results refactoring
1 year ago
9e878923e1
Refactor job and task results
1 year ago
d357be9209
Minor refactoring
1 year ago
479ff8e25e
Jobs reprocessing
1 year ago
60fdb7df3d
Multiple queued jobs of the same type
1 year ago
a317b4707a
Discard tasks when tenant is deleted
1 year ago
ee9237c416
Implement job cancellation
1 year ago
290fba4819
Job stats, REST API, tests
1 year ago
215c5dbb96
Jobs
1 year ago
edd7d6392a
Improvement after review
1 year ago
f8bf512a0a
Introduce PartitionedQueueResponseTemplate with consumer per partition; use it for EDQS requests processing
1 year ago
f361dfeb1e
Fix CF entity profiles cache initialization
1 year ago
12739b60ce
moved initFetchPackSize property to settings
1 year ago
de855e5236
Minor improvements for EDQS
1 year ago
cc5d9dbb2c
Added sync of fat edge consumer group into per edge group. Fixed clean up edge topics
1 year ago
Volodymyr Babak
Sergey Matvienko
Viacheslav Klimov
yevhenii_zahrebelnyi
Dmytro Skarzhynets
Andrii Landiak
dshvaika
IrynaMatveieva