ConfluentSchemaRegistry

class

class ConfluentSchemaRegistry(
    url: ConfluentSchemaRegistryUrlNameSpec,
    credentials: ConfluentSchemaRegistryCredentialsSpec | None = None,
    configs: CfgSpec | None = None,
)

Categories: source

Confluent-style schema registry attached to a KafkaStreamSrcConn.

Set as the connection's schema_registry for SR-aware serdes.

Parameters

parameter

urlConfluentSchemaRegistryUrlNameSpec (str | Secret)

Registry HTTP(S) URL; accepts a plain string or a Secret.

parameter

credentialsConfluentSchemaRegistryCredentialsSpec | None (UserPassword | None)

Optional UserPassword basic-auth credentials.

parameter

configsCfgSpec | None (dict | None)

Optional dict of registry-client overrides forwarded to confluent_kafka.schema_registry.SchemaRegistryClient (see CfgSpec).