Namespace Confluent.SchemaRegistry

Abstract base class for providers that supply Bearer authentication header values.

Associated subject name strategy implementation that uses a schema registry client and configuration to determine subject names.

This strategy queries schema registry for the associated subject name for the topic. The topic is passed as the resource name to schema registry. If there is a configuration property named "subject.name.strategy.kafka.cluster.id", then its value will be passed as the resource namespace; otherwise the value "-" will be passed as the resource namespace.

If more than one subject is returned from the query, an exception will be thrown. If no subjects are returned from the query, then the behavior will fall back to Topic strategy, unless the configuration property "subject.name.strategy.fallback.type" is set to "RECORD", "TOPIC_RECORD", or "NONE".

Represents an association between a subject and a resource in Schema Registry.

Information about an association to create or update.

Request to create or update associations.

Information about an association in a response.

Response from creating or updating associations.

Provider for authentication header values that uses Azure Instance Metadata Service (IMDS) to obtain bearer tokens.

A HTTP authentication header value provider implementing the 'Basic' scheme.

See: https://datatracker.ietf.org/doc/html/rfc7617

Provides bearer token authentication header values for schema registry requests based on OAuth2 client credentials flow.

A caching Schema Registry client.

The following method calls cache results:

• GetSchemaIdAsync(string, Schema, bool)
• GetSchemaIdAsync(string, string, bool)
• GetSchemaAsync(int, string)
• GetSchemaBySubjectAndIdAsync(string, int, string)
• RegisterSchemaAsync(string, Schema, bool)
• RegisterSchemaAsync(string, string, bool)
• GetRegisteredSchemaAsync(string, int, bool)
• LookupSchemaAsync(string, Schema, bool, bool)
• GetLatestSchemaAsync(string)

The following method calls do NOT cache results:

• GetAllSubjectsAsync()
• GetSubjectVersionsAsync(string)
• IsCompatibleAsync(string, Schema)
• IsCompatibleAsync(string, string)
• GetCompatibilityAsync(string)
• UpdateCompatibilityAsync(Compatibility, string)

An error action

A none action

Configuration property names specific to the schema registry client.

Extension methods for the ReferenceSubjectNameStrategy type.

Represents a Schema stored in Schema Registry.

A rule condition exception

A rule context.

A rule exception

A rule override.

A rule registry.

Represents a schema.

Represents a reference to a Schema stored in Schema Registry.

CachedSchemaRegistryClient configuration properties.

Configuration property names specific to the schema registry client.

Represents an error returned by Confluent Schema Registry.

Base functionality common to all configuration classes.

Provides authentication header values using a static bearer token.

Extension methods for the SubjectNameStrategy type.

Represents a schema ID or GUID.

An interface defining HTTP client authentication header values.

An interface defining HTTP client authentication header values.

Custom Reference Subject Name Strategy Interface

A rule action

A base class for rule executors and actions

A rule executor

Interface for decoding schema IDs or GUIDs.

Interface for encoding schema IDs or GUIDs.

An interface implemented by Confluent Schema Registry clients.

Auth credentials source.

Bearer auth credentials source.

Enumerates the schema compatibility types.

Subject name strategy for referenced schemas.

Rule kind.

Rule mode.

Rule phase.

The schema ID deserialization strategy.

The schema ID serialization strategy.

Enumerates the types of schema supported by Schema Registry.

Subject name strategy. Refer to: https://www.confluent.io/blog/put-several-event-types-kafka-topic/

Asynchronously construct the subject name under which the schema associated with a record should be registered in Schema Registry.

Construct the subject name under which a referenced schema should be registered in Schema Registry.

Construct the subject name under which the schema associated with a record should be registered in Schema Registry.