Skip to content

Commit cc61239

Browse files
jeremy001181Matt Howlett
authored andcommitted
Use returned schema id as key (#1587)
1 parent e575d6b commit cc61239

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/Confluent.SchemaRegistry/CachedSchemaRegistryClient.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -302,7 +302,7 @@ public async Task<int> GetSchemaIdAsync(string subject, Schema schema)
302302
// throws SchemaRegistryException if schema is not known.
303303
var registeredSchema = await restService.LookupSchemaAsync(subject, schema, true).ConfigureAwait(continueOnCapturedContext: false);
304304
idBySchema[schema.SchemaString] = registeredSchema.Id;
305-
schemaById[schemaId] = registeredSchema.Schema;
305+
schemaById[registeredSchema.Id] = registeredSchema.Schema;
306306
schemaId = registeredSchema.Id;
307307
}
308308

0 commit comments

Comments
 (0)