diff --git a/README.md b/README.md index df76d7d8..0dc4d3da 100644 --- a/README.md +++ b/README.md @@ -14,7 +14,7 @@ repositories { } dependencies { - implementation group: 'org.radarcns', name: 'radar-commons', version: '0.11.0' + implementation group: 'org.radarcns', name: 'radar-commons', version: '0.11.1' } ``` @@ -26,7 +26,7 @@ repositories { } dependencies { - implementation group: 'org.radarcns', name: 'radar-commons-server', version: '0.11.0' + implementation group: 'org.radarcns', name: 'radar-commons-server', version: '0.11.1' } ``` @@ -40,7 +40,7 @@ repositories { } dependencies { - testImplementation group: 'org.radarcns', name: 'radar-commons-testing', version: '0.11.0' + testImplementation group: 'org.radarcns', name: 'radar-commons-testing', version: '0.11.1' } ``` @@ -53,7 +53,7 @@ repositories { } dependencies { - runtimeOnly group: 'org.radarcns', name: 'radar-commons-unsafe', version: '0.11.0' + runtimeOnly group: 'org.radarcns', name: 'radar-commons-unsafe', version: '0.11.1' } ``` @@ -78,7 +78,7 @@ configurations.all { } dependencies { - compile group: 'org.radarcns', name: 'radar-commons', version: '0.11.1-SNAPSHOT', changing: true + compile group: 'org.radarcns', name: 'radar-commons', version: '0.11.2-SNAPSHOT', changing: true } ``` diff --git a/build.gradle b/build.gradle index b283a12f..65d59163 100644 --- a/build.gradle +++ b/build.gradle @@ -36,7 +36,7 @@ subprojects { // Configuration // //---------------------------------------------------------------------------// - version = '0.11.0' + version = '0.11.1' group = 'org.radarcns' ext.githubRepoName = 'RADAR-CNS/RADAR-Commons' diff --git a/radar-commons/src/main/java/org/radarcns/producer/rest/SchemaRetriever.java b/radar-commons/src/main/java/org/radarcns/producer/rest/SchemaRetriever.java index 8fcaf32e..1a4b421b 100644 --- a/radar-commons/src/main/java/org/radarcns/producer/rest/SchemaRetriever.java +++ b/radar-commons/src/main/java/org/radarcns/producer/rest/SchemaRetriever.java @@ -166,19 +166,14 @@ public void addSchemaMetadata(String topic, boolean ofValue, ParsedSchemaMetadat */ public ParsedSchemaMetadata getOrSetSchemaMetadata(String topic, boolean ofValue, Schema schema, int version) throws IOException { - ParsedSchemaMetadata metadata; try { - metadata = getSchemaMetadata(topic, ofValue, version); - if (metadata.getSchema().equals(schema)) { - return metadata; - } + return getSchemaMetadata(topic, ofValue, version); } catch (IOException ex) { logger.warn("Schema for {} value was not yet added to the schema registry.", topic); + ParsedSchemaMetadata metadata = new ParsedSchemaMetadata(null, null, schema); + addSchemaMetadata(topic, ofValue, metadata); + return metadata; } - - metadata = new ParsedSchemaMetadata(null, null, schema); - addSchemaMetadata(topic, ofValue, metadata); - return metadata; } private class SchemaRequestBody extends RequestBody {