fix typo options.useSchemaRegistry -> useSchemaRegistry

This commit is contained in:
Ricardo Georgel 2021-06-05 21:22:32 -03:00
parent e5e0929332
commit 87b0e99923

View file

@ -193,7 +193,7 @@ export class KafkaTrigger implements INodeType {
} catch (error) { } } catch (error) { }
} }
if (options.useSchemaRegistry) { if (useSchemaRegistry) {
try { try {
value = await registry.decode(message.value as Buffer); value = await registry.decode(message.value as Buffer);
} catch (error) { } } catch (error) { }