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 |
|
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 |
|