private void delRecordFromCaches(String recordKey) {
        GroupConsumeCtrlEntity curEntity =
                consumeCtrlCache.remove(recordKey);
        if (curEntity == null) {
            return;
        }
        // add topic index
        ConcurrentHashSet<String> keySet =
                topic2RecordCache.get(curEntity.getTopicName());
        if (keySet != null) {
            keySet.remove(recordKey);
            if (keySet.isEmpty()) {
                topic2RecordCache.remove(curEntity.getTopicName(), new ConcurrentHashSet<>());
            }
        }
        // delete group index
        keySet = group2RecordCache.get(curEntity.getGroupName());
        if (keySet != null) {
            keySet.remove(recordKey);
            if (keySet.isEmpty()) {
                group2RecordCache.remove(curEntity.getGroupName(), new ConcurrentHashSet<>());
            }
        }
    }
Delete the cached record

@param recordKey  the record key to be deleted
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/AbsConsumeCtrlMapperImpl.java