Class KafkaSchemaRegistryConfigurationBuilder

Namespace

Silverback.Messaging.Configuration.Kafka.SchemaRegistry

Assembly

Silverback.Integration.Kafka.SchemaRegistry.dll

Builds the KafkaSchemaRegistryConfiguration.

public class KafkaSchemaRegistryConfigurationBuilder

Inheritance

object

KafkaSchemaRegistryConfigurationBuilder

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

KafkaSchemaRegistryConfigurationBuilder()

public KafkaSchemaRegistryConfigurationBuilder()

Methods

Build()

Builds the KafkaSchemaRegistryConfiguration instance.

public KafkaSchemaRegistryConfiguration Build()

Returns

KafkaSchemaRegistryConfiguration

The KafkaSchemaRegistryConfiguration.

DisableSslCertificateVerification()

Disables the SSL certificate validation.

public KafkaSchemaRegistryConfigurationBuilder DisableSslCertificateVerification()

Returns

KafkaSchemaRegistryConfigurationBuilder

The KafkaSchemaRegistryConfigurationBuilder so that additional calls can be chained.

EnableSslCertificateVerification()

Enables the SSL certificate validation.

public KafkaSchemaRegistryConfigurationBuilder EnableSslCertificateVerification()

Returns

KafkaSchemaRegistryConfigurationBuilder

The KafkaSchemaRegistryConfigurationBuilder so that additional calls can be chained.

WithBasicAuthCredentialsSource(AuthCredentialsSource?)

Sets the source of the basic authentication credentials. This specifies whether the credentials are specified in the BasicAuthUserInfo or they are inherited from the producer or consumer configuration.

public KafkaSchemaRegistryConfigurationBuilder WithBasicAuthCredentialsSource(AuthCredentialsSource? basicAuthCredentialsSource)

Parameters

basicAuthCredentialsSource AuthCredentialsSource?

The source of the basic authentication credentials.

Returns

KafkaSchemaRegistryConfigurationBuilder

The KafkaSchemaRegistryConfigurationBuilder so that additional calls can be chained.

WithBasicAuthUserInfo(string?)

Sets the basic authentication credentials in the form {username}:{password}.

public KafkaSchemaRegistryConfigurationBuilder WithBasicAuthUserInfo(string? basicAuthUserInfo)

Parameters

basicAuthUserInfo string

The basic authentication credentials in the form {username}:{password}.

Returns

KafkaSchemaRegistryConfigurationBuilder

The KafkaSchemaRegistryConfigurationBuilder so that additional calls can be chained.

WithLatestCacheTtlSecs(int?)

Sets the TTL in seconds for caches holding latest schemas, or -1 for no TTL.

public KafkaSchemaRegistryConfigurationBuilder WithLatestCacheTtlSecs(int? latestCacheTtlSecs)

Parameters

latestCacheTtlSecs int?

The TTL in seconds for caches holding latest schemas, or -1 for no TTL.

Returns

KafkaSchemaRegistryConfigurationBuilder

The KafkaSchemaRegistryConfigurationBuilder so that additional calls can be chained.

WithMaxCachedSchemas(int?)

Sets the maximum number of schemas that are cached by the schema registry client.

public KafkaSchemaRegistryConfigurationBuilder WithMaxCachedSchemas(int? maxCachedSchemas)

Parameters

maxCachedSchemas int?

The maximum number of schemas that are cached by the schema registry client.

Returns

KafkaSchemaRegistryConfigurationBuilder

The KafkaSchemaRegistryConfigurationBuilder so that additional calls can be chained.

WithMaxRetries(int?)

Sets the maximum number of retries for a request.

public KafkaSchemaRegistryConfigurationBuilder WithMaxRetries(int? maxRetries)

Parameters

maxRetries int?

The maximum number of retries for a request.

Returns

KafkaSchemaRegistryConfigurationBuilder

The KafkaSchemaRegistryConfigurationBuilder so that additional calls can be chained.

WithRequestTimeoutMs(int?)

Sets the timeout in milliseconds for the requests to the Confluent schema registry.

public KafkaSchemaRegistryConfigurationBuilder WithRequestTimeoutMs(int? requestTimeoutMs)

Parameters

requestTimeoutMs int?

The timeout in milliseconds for the requests to the Confluent schema registry.

Returns

KafkaSchemaRegistryConfigurationBuilder

The KafkaSchemaRegistryConfigurationBuilder so that additional calls can be chained.

WithRetriesMaxWaitMs(int?)

Sets the time to wait for any retry in milliseconds.

public KafkaSchemaRegistryConfigurationBuilder WithRetriesMaxWaitMs(int? retriesMaxWaitMs)

Parameters

retriesMaxWaitMs int?

The time to wait for any retry in milliseconds.

Returns

KafkaSchemaRegistryConfigurationBuilder

The KafkaSchemaRegistryConfigurationBuilder so that additional calls can be chained.

WithRetriesWaitMs(int?)

Sets the time to wait for the first retry in milliseconds.

public KafkaSchemaRegistryConfigurationBuilder WithRetriesWaitMs(int? retriesWaitMs)

Parameters

retriesWaitMs int?

The time to wait for the first retry in milliseconds.

Returns

KafkaSchemaRegistryConfigurationBuilder

The KafkaSchemaRegistryConfigurationBuilder so that additional calls can be chained.

WithSslCaLocation(string?)

Sets the file or directory path to the CA certificate(s) for verifying the registry's key.

public KafkaSchemaRegistryConfigurationBuilder WithSslCaLocation(string? sslCaLocation)

Parameters

sslCaLocation string

The file or directory path to the CA certificate(s) for verifying the registry's key.

Returns

KafkaSchemaRegistryConfigurationBuilder

The KafkaSchemaRegistryConfigurationBuilder so that additional calls can be chained.

WithSslKeystoreLocation(string?)

Sets the path to the client's keystore (PKCS#12) used for the authentication.

public KafkaSchemaRegistryConfigurationBuilder WithSslKeystoreLocation(string? sslKeystoreLocation)

Parameters

sslKeystoreLocation string

The path to the client's keystore (PKCS#12) used for the authentication.

Returns

KafkaSchemaRegistryConfigurationBuilder

The KafkaSchemaRegistryConfigurationBuilder so that additional calls can be chained.

WithSslKeystorePassword(string?)

Sets the client's keystore (PKCS#12) password.

public KafkaSchemaRegistryConfigurationBuilder WithSslKeystorePassword(string? sslKeystorePassword)

Parameters

sslKeystorePassword string

The client's keystore (PKCS#12) password.

Returns

KafkaSchemaRegistryConfigurationBuilder

The KafkaSchemaRegistryConfigurationBuilder so that additional calls can be chained.

WithUrl(string?)

Sets the comma-separated list of URLs for schema registry instances that are used to register or lookup schemas.

public KafkaSchemaRegistryConfigurationBuilder WithUrl(string? url)

Parameters

url string

The comma-separated list of URLs for schema registry instances.

Returns

KafkaSchemaRegistryConfigurationBuilder

The KafkaSchemaRegistryConfigurationBuilder so that additional calls can be chained.