Add option to return the headers of the message

packages/nodes-base/nodes/Kafka/KafkaTrigger.node.ts

@@ -122,6 +122,13 @@ export class KafkaTrigger implements INodeType {
 						default: 30000,
 						description: 'The time to await a response in ms.',
 					},
+					{
+						displayName: 'Return headers',
+						name: 'returnHeaders',
+						type: 'boolean',
+						default: false,
+						description: 'Return the headers received from Kafka',
+					},
 				],
 			},
 		],
@@ -199,6 +206,16 @@ export class KafkaTrigger implements INodeType {
 						} catch (error) { }
 					}
 
+					if (options.returnHeaders) {
+						const headers: {[key: string]: string} = {};
+						for (const key in message.headers) {
+							const header = message.headers[key];
+							headers[key] = header?.toString('utf8') || '';
+						}
+
+						data.headers = headers;
+					}
+
 					data.message = value;
 					data.topic = topic;