dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
21,161 Commits 106 Branches 71 Tags
Commit Graph

697 Commits

Author SHA1 Message Date
Igor Kulikov
190bba72f9 Temp Version set to 3.9.0-RC 2024-12-04 16:52:14 +02:00
Igor Kulikov
8ac0468edd Version set to 4.0.0-SNAPSHOT 2024-12-04 16:51:03 +02:00
Dmytro Skarzhynets
68aaf3c918 Merge branch 'master' into safe-scheduler 
# Conflicts:
#	common/util/src/main/java/org/thingsboard/common/util/ThingsBoardExecutors.java
 2024-12-02 17:43:07 +02:00
Andrii Landiak
988dfce500 Refactor KafkaEdgeTopicsCleanUpService to properly clean up both deleted edges and expired topics 2024-11-29 15:18:27 +02:00
Andrii Landiak
63b53a4a45 Final improvement after review 2024-11-28 16:51:55 +02:00
Andrii Landiak
76bed44705 Minor improvement 2024-11-28 15:16:20 +02:00
Andrii Landiak
b796355554 Merge remote-tracking branch 'upstream/master' into feature/edge-kafka-events 2024-11-26 09:42:31 +02:00
Andrii Landiak
c388034d01 Delete EdgeGrpcSession interface: use abstract instead 2024-11-22 10:26:06 +02:00
Andrii Landiak
b981281205 Fix tests 2024-11-01 11:37:11 +02:00
Andrii Landiak
50a55d15a9 Add poll properties for edge-event kafka poll 2024-10-31 18:12:16 +02:00
Andrii Landiak
38eeada8ec Implement clean up service to clear empty edge topics 2024-10-30 12:29:07 +02:00
Andrii Landiak
3ecbd3258e Introduce kafka approach to work with edge-event instead of postgres 2024-10-22 12:38:57 +03:00
ViacheslavKlimov
2c0b7eb2b3 Deprecate all queue types except Kafka and in-memory 2024-10-18 14:11:59 +03:00
Igor Kulikov
fdbe59c610 Version set to 3.9.0-SNAPSHOT 2024-10-14 18:32:35 +03:00
Igor Kulikov
d11f866856 Version set to 3.8.1-RC 2024-10-14 18:27:21 +03:00
Igor Kulikov
b4124f7c4c Merge with RC 2024-09-26 11:10:56 +03:00
Igor Kulikov
4d705f26fd Version set to 3.8.0-RC 2024-09-26 11:09:26 +03:00
Igor Kulikov
3dadc34b5b Version set to 3.9.0-SNAPSHOT 2024-09-26 10:38:27 +03:00
Igor Kulikov
025fb1ca8c Version set to 3.8.0 2024-09-26 09:46:57 +03:00
Dmytro Skarzhynets
bbe328d158 Implemented safe scheduled thread pool 2024-09-18 19:46:17 +03:00
ViacheslavKlimov
ac460e8c3b Merge remote-tracking branch 'origin/hotfix/3.7' 2024-09-17 12:45:27 +03:00
YevhenBondarenko
f10f63bb8a fixed concurrent modification in TopicService 2024-09-17 11:25:50 +02:00
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
39049eecd9 Remove redundant logging of thread name and scheduler name 2024-09-04 17:11:53 +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
5602807dbe
Introduce Edge queue to handle edge notification messages 2024-08-29 12:51:20 +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
Andrii Landiak
5ca6ad03e3 CE: optimize java imports 2024-08-01 11:12:10 +03:00
ViacheslavKlimov
68c8bf8db7 Merge remote-tracking branch 'origin/hotfix/3.7' 2024-07-10 10:48:49 +03:00
ViacheslavKlimov
88af44870e Check for queueName emptiness on partition resolve 2024-07-04 14:22:32 +03:00
Igor Kulikov
468c007882 Version set to 3.7.1-SNAPSHOT 2024-06-20 15:53:41 +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
11a8e5c7eb Merge remote-tracking branch 'ce/master' into feature/kafka-consumer-group-per-partition 
# Conflicts:
#	application/src/main/java/org/thingsboard/server/service/queue/ruleengine/TbQueueConsumerTask.java
#	application/src/main/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManager.java
#	application/src/test/java/org/thingsboard/server/service/queue/ruleengine/TbRuleEngineQueueConsumerManagerTest.java
#	common/queue/src/main/java/org/thingsboard/server/queue/kafka/TbKafkaAdmin.java
 2024-05-22 14:37:46 +02:00
Andrew Shvayka
1579e1e1a3
Merge pull request #10757 from smatvienko-tb/feature/kafka-confluent-out-of-the-box 
Kafka Confluent compatibility out of the box: segment.bytes:52428800
 2024-05-22 12:26:40 +03:00
Viacheslav Klimov
5809d014de
Queue option to duplicate msgs to all partitions (#10815) 
* Queue config option to duplicate msgs to all partitions

* UI for queue config option to duplicate msgs to all partitions

* Fixes for msg duplication; add tests

* Introduce TbRuleEngineProducerService

* Use TbRuleEngineProducerService in TbClusterService

* Fix DefaultTbClusterServiceTest

* Add correlationId to TbMsg

* Refactor TbMsg

* Support msg duplication for all msg types
 2024-05-22 12:11:32 +03:00
Sergey Matvienko
5e3ff6fe20 minor cleanup 2024-05-22 09:02:01 +02:00
ViacheslavKlimov
1a264dafa7 Fix TbKafkaSettingsTest 2024-05-16 14:34:50 +03:00
ViacheslavKlimov
e8d14f37cb Improvements for Kafka admin creation 2024-05-16 13:24:49 +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
ViacheslavKlimov
15d189ead7 Refactoring for consumer manager 2024-05-07 15:13:52 +03:00
ViacheslavKlimov
9f6156a0fb Merge remote-tracking branch 'origin/master' into feature/parallel-core-consumer 2024-05-07 14:57:19 +03:00
Sergey Matvienko
8519387ca7 Rule engine: Kafka consumer group per partition 2024-05-07 00:14:15 +02:00
ViacheslavKlimov
f23061a9ae Fix notification deduplication service (ConcurrentModificationException for deduplicationDurations map) 2024-05-06 12:22:26 +03: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