From 6336158d552b0d97d1d405c7ca914a1dd4e46ae2 Mon Sep 17 00:00:00 2001
From: Jan Oberhauser <jan.oberhauser@gmail.com>
Date: Sat, 8 Jan 2022 11:47:24 +0100
Subject: [PATCH] :shirt: Fix lint issue

---
 packages/nodes-base/nodes/Kafka/KafkaTrigger.node.ts | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/packages/nodes-base/nodes/Kafka/KafkaTrigger.node.ts b/packages/nodes-base/nodes/Kafka/KafkaTrigger.node.ts
index 935cb4fe40..4a882bdcbe 100644
--- a/packages/nodes-base/nodes/Kafka/KafkaTrigger.node.ts
+++ b/packages/nodes-base/nodes/Kafka/KafkaTrigger.node.ts
@@ -209,9 +209,9 @@ export class KafkaTrigger implements INodeType {
 						} catch (error) { }
 					}
 
-					if (options.returnHeaders) {
+					if (options.returnHeaders && message.headers) {
 						const headers: {[key: string]: string} = {};
-						for (const key in message.headers) {
+						for (const key of Object.keys(message.headers)) {
 							const header = message.headers[key];
 							headers[key] = header?.toString('utf8') || '';
 						}