1215 CachingCachingRegistryClient stores data by wrong keys resulting in fetch operations always missing.

Resolves #1216
This commit is contained in:
jmaxwell
2018-02-13 10:14:09 -06:00
committed by Oleg Zhurakousky
parent 0463f7939d
commit a160cd7ea8

View File

@@ -47,8 +47,8 @@ public class CachingRegistryClient implements SchemaRegistryClient {
@Override
public SchemaRegistrationResponse register(String subject, String format, String schema) {
SchemaRegistrationResponse response = delegate.register(subject, format, schema);
cacheManager.getCache(ID_CACHE).put(response.getSchemaReference(), schema);
cacheManager.getCache(REF_CACHE).put(response.getId(), schema);
cacheManager.getCache(ID_CACHE).put(response.getId(), schema);
cacheManager.getCache(REF_CACHE).put(response.getSchemaReference(), schema);
return response;
}