ConfluentSchemaRegistry

Description:

Provides a Schema Registry that interacts with the Confluent Schema Registry so that those Schemas that are stored in the Confluent Schema Registry can be used in NiFi. The Confluent Schema Registry has a notion of a "subject" for schemas, which is their terminology for a schema name. When a Schema is looked up by name by this registry, it will find a Schema in the Confluent Schema Registry with that subject.

Tags:

schema, registry, confluent, avro, kafka

Properties:

In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, whether a property supports the NiFi Expression Language, and whether a property is considered "sensitive", meaning that its value will be encrypted. Before entering a value in a sensitive property, ensure that the nifi.properties file has an entry for the property nifi.sensitive.props.key.

NameDefault ValueAllowable ValuesDescription
Schema Registry URLshttp://localhost:8081A comma-separated list of URLs of the Schema Registry to interact with
Supports Expression Language: true (will be evaluated using variable registry only)
SSL Context ServiceController Service API:
SSLContextService
Implementations: StandardSSLContextService
StandardRestrictedSSLContextService
Specifies the SSL Context Service to use for interacting with the Confluent Schema Registry
Communications Timeout30 secsSpecifies how long to wait to receive data from the Schema Registry before considering the communications a failure
Cache Size1000Specifies how many Schemas should be cached from the Schema Registry
Cache Expiration1 hourSpecifies how long a Schema that is cached should remain in the cache. Once this time period elapses, a cached version of a schema will no longer be used, and the service will have to communicate with the Schema Registry again in order to obtain the schema.
Authentication TypeNONE
  • BASIC
  • NONE
HTTP Client Authentication Type for Confluent Schema Registry
UsernameUsername for authentication to Confluent Schema Registry

This Property is only considered if the <Authentication Type> Property has a value of "BASIC".
PasswordPassword for authentication to Confluent Schema Registry
Sensitive Property: true

This Property is only considered if the <Authentication Type> Property has a value of "BASIC".

State management:

This component does not store state.

Restricted:

This component is not restricted.

System Resource Considerations:

None specified.