diff --git a/common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java b/common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java index e8f54b8d73..2d900398e3 100644 --- a/common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java +++ b/common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java @@ -33,9 +33,9 @@ public class TopicRouteData extends RemotingSerializable { public TopicRouteData cloneTopicRouteData() { TopicRouteData topicRouteData = new TopicRouteData(); - topicRouteData.setQueueDatas(new ArrayList()); - topicRouteData.setBrokerDatas(new ArrayList()); - topicRouteData.setFilterServerTable(new HashMap>()); + topicRouteData.setQueueDatas(new ArrayList<>()); + topicRouteData.setBrokerDatas(new ArrayList<>()); + topicRouteData.setFilterServerTable(new HashMap<>()); topicRouteData.setOrderTopicConf(this.orderTopicConf); if (this.queueDatas != null) {