ViacheslavKlimov
c4d0867635
Merge branch 'hotfix/3.7' of github.com:thingsboard/thingsboard into master-hotfix-3.7
2024-09-10 11:42:09 +03:00
ThingsBoard Bot
189778efb9
License header format
2024-09-09 14:57:22 +00:00
Andrew Shvayka
e286a051df
Merge pull request #8696 from driesva/rabbitmq-max-poll-messages
...
fix: Slow RabbitMQ message polling
2024-09-09 17:45:30 +03:00
Dmytro Skarzhynets
f6a1c14353
Fix last activity not being reported when activity reporting period ends
2024-09-04 16:45:58 +03:00
Andrii Landiak
c6ee0bff19
Add edgeIdsCache to decrease number of calls to db for findRelatedEdgeByEntityId
2024-08-27 12:41:39 +03:00
ViacheslavKlimov
92cabebb04
Fix unrecognized Kafka config 'session.timeout.ms'
2024-08-14 11:52:13 +03:00
Andrew Shvayka
a8dee2643b
Merge pull request #10728 from smatvienko-tb/feature/kafka-consumer-group-per-partition
...
Rule engine: Kafka consumer group per partition
2024-05-22 18:11:25 +03:00
Sergey Matvienko
258c26ed04
Kafka groupId syncOffsets from a fat group to a single-partition group
2024-05-15 16:23:20 +02:00
Sergey Matvienko
34cfd588b1
mvn license:format
2024-05-13 17:26:59 +02:00
Sergey Matvienko
d89b14e359
Kafka Confluent compatibility out of the box: segment.bytes:26214400 increased segment.bytes:52428800
2024-05-10 11:45:52 +02:00
Sergey Matvienko
07de3b975f
TbKafkaAdmin WIP
2024-05-08 13:58:21 +02:00
Oleksandra Matviienko
63df92e995
JUnit5 migration in common. Junit-platform.properties and logback-test.xml where added to java resource directories if needed.
...
Signed-off-by: Oleksandra Matviienko <al.zzzeebra@gmail.com>
2024-04-26 23:55:17 +02:00
Igor Kulikov
c5a72ed8df
Update license header to 2024 year.
2024-01-09 10:46:16 +02:00
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
2023-10-26 17:07:16 +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
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
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
driesva
ee45763ceb
fix: Slow RabbitMQ message polling
...
Configurable RabbitMQ polling in order that more messages can be obtained from the queue during a poll.
Fixes #8445
2023-06-02 09:11:49 +02:00
YevhenBondarenko
fbf9773a61
optimize imports
2023-05-02 10:57:58 +02:00
Sergey Matvienko
26ed90c534
kafka settings: kafka yaml parameters added for microservices same as thingsboard.yml . PropertyUtils added, duplicated code refactored to getProps. TB_QUEUE_KAFKA_REQUEST_TIMEOUT_MS and TB_QUEUE_KAFKA_SESSION_TIMEOUT_MS moved from other to main properties. Other yaml props is deprecated. other-inline added TB_QUEUE_KAFKA_OTHER_PROPERTIES. Tests added.
2023-04-18 10:54:10 +02:00
Sergey Matvienko
e621a21df3
kafka settings: test added, refactored to use configureSSL exact once
2023-04-18 10:54:10 +02:00
Igor Kulikov
cbdc4517e4
Update license header year to 2023
2023-01-31 10:43:56 +02:00
ShvaykaD
f5e20b5a3e
move default queue names and topics to DataConstants
2023-01-26 13:37:19 +02:00
Sergey Matvienko
cffd0a3a1e
QueueKey toString for better logging experience
2022-06-21 18:12:29 +03:00
Sergey Matvienko
f8a6751182
InMemoryStorage performance improved. Many test cases added since it is essential piece of code.
2022-04-15 16:46:19 +03:00
Sergey Matvienko
b9b4d06376
DefaultInMemoryStorageTest test added on Poll before improvement
2022-04-15 16:46:15 +03:00
Sergey Matvienko
d18533a88f
InMemoryStorage extracted
2022-04-15 16:46:09 +03:00
Sergey Matvienko
9a2bc5ab9d
InMemoryStorage refactored from the static singleton to the Spring Bean
2022-04-14 13:20:34 +03:00
Igor Kulikov
da4c742872
Update license year to 2022
2022-01-17 14:07:46 +02:00
Sergey Matvienko
eab54435eb
fixed license header for InMemoryStorageTest
2021-10-28 15:03:13 +03:00
Sergey Matvienko
d98419106b
InMemoryStorage: added getLagTotal to be able to await while queue have any messages (no guarantee that messages was processed).
2021-10-18 16:47:43 +03:00
Igor Kulikov
b173e0799c
Update OS package plugin version. Code cleanup.
2021-09-07 11:47:43 +03:00
Sergey Matvienko
bec228bc83
test: removed unnecessary stubbing on DefaultTbQueueRequestTemplateTest
2021-06-17 13:42:37 +03:00
Sergey Matvienko
aaedb9e879
DefaultTbQueueRequestTemplateTest updated licence header for CE
2021-06-17 13:35:20 +03:00
Sergey Matvienko
ed44ac8f19
test fixed for DefaultTbQueueRequestTemplateTest
2021-06-17 13:27:19 +03:00
Sergey Matvienko
9daa43a115
queue request template: sleep on exception shortened according to the stopwatch. test adjusted
2021-06-17 13:02:15 +03:00
Sergey Matvienko
928b8f0fd9
test: refactored for assertThat for DefaultTbQueueRequestTemplateTest
2021-06-17 11:50:00 +03:00
Sergey Matvienko
28235732c6
test: fixed class DefaultTbQueueRequestTemplate
2021-06-17 11:49:45 +03:00
Sergey Matvienko
9666986156
test: added failed test for FetchAndProcessResponses when request removed as staled too early DefaultTbQueueRequestTemplate
2021-06-17 11:49:33 +03:00
Sergey Matvienko
d5fffa5002
test: added failed test case with overflow maxPendingRequests for DefaultTbQueueRequestTemplate.send(). another refactoring for easy mocking.
2021-06-17 11:44:24 +03:00
Sergey Matvienko
872717828c
test: refactored and added mainLoop test DefaultTbQueueRequestTemplate
2021-06-17 11:41:47 +03:00
Sergey Matvienko
9ed948933e
test: added init stop test for DefaultTbQueueRequestTemplate
2021-06-17 11:41:35 +03:00
