Skip to content

Commit 3513c4d

Browse files
committed
for #3666 for delete lmq topic comment
1 parent 4b80706 commit 3513c4d

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

store/src/main/java/org/apache/rocketmq/store/MessageStore.java

+5-2
Original file line numberDiff line numberDiff line change
@@ -400,8 +400,11 @@ QueryMessageResult queryMessage(final String topic, final String key, final int
400400

401401
/**
402402
* Clean unused lmq topic.
403-
*
404-
* @param topic valid topic
403+
* When calling to clean up the lmq topic,
404+
* the lmq topic cannot be used to write messages at the same time,
405+
* otherwise the messages of the cleaning lmq topic may be lost,
406+
* please call this method with caution
407+
* @param topic lmq topic
405408
*/
406409
void cleanUnusedLmqTopic(String topic);
407410
}

0 commit comments

Comments
 (0)