Skip to content

Commit b26b2f9

Browse files
read the system retained messages on init
1 parent dc016d2 commit b26b2f9

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

application/src/main/java/org/thingsboard/mqtt/broker/service/mqtt/retain/RetainedMsgConsumerImpl.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -104,9 +104,6 @@ public Map<String, RetainedMsg> initLoad() throws QueuePersistenceException {
104104
totalMessageCount += packSize;
105105
for (TbProtoQueueMsg<RetainedMsgProto> msg : messages) {
106106
String topic = msg.getKey();
107-
if (topic.startsWith(BrokerConstants.SYSTEMS_TOPIC_PREFIX)) {
108-
continue;
109-
}
110107
if (isRetainedMsgProtoEmpty(msg.getValue())) {
111108
// this means Kafka log compaction service haven't cleared empty message yet
112109
log.trace("[{}] Encountered empty RetainedMsg.", topic);

0 commit comments

Comments
 (0)