diff --git a/src/components/Avro/schema_registry/CachedSchemaRegistryClient.ts b/src/components/Avro/schema_registry/CachedSchemaRegistryClient.ts index 1d26d9f..377e5bf 100644 --- a/src/components/Avro/schema_registry/CachedSchemaRegistryClient.ts +++ b/src/components/Avro/schema_registry/CachedSchemaRegistryClient.ts @@ -23,6 +23,7 @@ export class CachedSchemaRegistryClient implements SchemaRegistry { host: config.host, port: config.port, logger: (config.logger !== undefined) ? config.logger : this._defaultLogger, + protocol: config.protocol, }; this.client = new RegistryClient(clientConfig); }