diff --git a/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java b/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java index 6b9cf159383..2e1c4d0a777 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java @@ -231,7 +231,7 @@ public TopicQueueMappingContext buildTopicQueueMappingContext(TopicRequestHeader List mappingItemList = TopicQueueMappingDetail.getMappingInfo(mappingDetail, globalId); LogicQueueMappingItem leaderItem = null; if (mappingItemList != null - && mappingItemList.size() > 0) { + && !mappingItemList.isEmpty()) { leaderItem = mappingItemList.get(mappingItemList.size() - 1); } return new TopicQueueMappingContext(topic, globalId, mappingDetail, mappingItemList, leaderItem);