diff --git a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicManagerServiceImpl.java b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicManagerServiceImpl.java
index 0b42d068..9e381587 100644
--- a/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicManagerServiceImpl.java
+++ b/kafka-manager-core/src/main/java/com/xiaojukeji/kafka/manager/service/service/impl/TopicManagerServiceImpl.java
@@ -50,6 +50,8 @@ import java.util.stream.Collectors;
 public class TopicManagerServiceImpl implements TopicManagerService {
     private static final Logger LOGGER = LoggerFactory.getLogger(TopicManagerServiceImpl.class);
 
+    private static final String CONSUMER_OFFSETS_TOPIC = "__consumer_offsets";
+
     @Autowired
     private TopicDao topicDao;
 
@@ -275,6 +277,8 @@ public class TopicManagerServiceImpl implements TopicManagerService {
         }
         Map<Long, Map<String, TopicDO>> topicMap = new HashMap<>(appList.size());
         for (TopicDO topicDO: topicList) {
+            if (topicDO.getTopicName().equals(CONSUMER_OFFSETS_TOPIC))
+                continue;
             Map<String, TopicDO> subTopicMap = topicMap.getOrDefault(topicDO.getClusterId(), new HashMap<>());
             subTopicMap.put(topicDO.getTopicName(), topicDO);
             topicMap.put(topicDO.getClusterId(), subTopicMap);