diff --git a/packages/nodes-base/nodes/Kafka/KafkaTrigger.node.ts b/packages/nodes-base/nodes/Kafka/KafkaTrigger.node.ts
index c2ab8db751..c4587beca3 100644
--- a/packages/nodes-base/nodes/Kafka/KafkaTrigger.node.ts
+++ b/packages/nodes-base/nodes/Kafka/KafkaTrigger.node.ts
@@ -193,7 +193,7 @@ export class KafkaTrigger implements INodeType {
 						} catch (error) { }
 					}
 
-					if (options.useSchemaRegistry) {
+					if (useSchemaRegistry) {
 						try {
 							value = await registry.decode(message.value as Buffer);
 						} catch (error) { }