in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/handler/SchemaHandler.java [275:283]
public void entryUpdated(EntryEvent<String, SchemaInfo> update) {
if (update == null || update.getValue() == null || update.getValue().getLastRecord() == null) {
return;
}
SchemaRecordInfo lastSchemaRecordInfo = update.getValue().getLastRecord();
lastSchemaRecordInfo.getSubjects().forEach(subject -> {
subjectCache.put(subject.fullName(), update.getValue().getLastRecord());
});
}