public GetSchemaResponse getSchemaByRecordId()

in client/src/main/java/org/apache/rocketmq/schema/registry/client/CachedSchemaRegistryClient.java [298:317]

• 18 lines of code
• 3 McCabe index (conditional complexity)

    public GetSchemaResponse getSchemaByRecordId(String cluster, String tenant, String subject,
        long recordId) throws RestClientException, IOException {
        SubjectAndId subjectAndId = new SubjectAndId(cluster, tenant, subject, recordId);
        GetSchemaResponse result = schemaCacheBySubjectAndId.getIfPresent(subjectAndId);
        if (result != null) {
            return result;
        }
        String subjectFullName = String.format("%s/%s/%s", cluster, tenant, subject);

        Set<Long> recordIds = subjectToId.get(subjectFullName);
        if (recordIds == null) {
            recordIds = new HashSet<>();
        }
        recordIds.add(recordId);
        subjectToId.put(subjectFullName, recordIds);

        result = restService.getSchemaByRecordId(cluster, tenant, subject, recordId);
        schemaCacheBySubjectAndId.put(subjectAndId, result);
        return result;
    }