confluent-kafka-go
confluent-kafka-go copied to clipboard
RefreshLatestSchemaMetadataCache implementation refreshing latestToSchemaCache entries
RefreshLatestSchemaMetadataCache implementation refreshing latestToSchemaCache entries Issue #1274
Why?: in order to allow refresh the internal state of cache that belongs to, the first time that GetLatestSchemaMetadata method is executed (client#latestToSchemaCache) or when the ttl cache is exired
Implementation:
RefreshLatestSchemaMetadataCachemethod implementation into schemaregistry_client.go, assuming variadic string with subjects arguments, iterating it and getting the schema-metadata for each one- by each schema-metadata, when it call occurs and get the schema-metadata into
&SchemaMetadata- lock
latestToSchemaCacheLockfor possible R/W ah updatelatestToSchemaCacheinternal-state - when an error occurs when calling schema-metadata obtention, it puts in a
multierrorand returns the possible errors to be aware about this behavior
- lock
Thank you for your submission! We really appreciate it. Like many open source projects, we ask that you sign our Contributor License Agreement before we can accept your contribution.
You have signed the CLA already but the status is still pending? Let us recheck it.
Closed in favor of https://github.com/confluentinc/confluent-kafka-go/pull/1305