Add key to kafka message

jbacklund · September 27, 2022, 7:35am

Hey, Is it possible to add key to a Kafka message? Looking in the code it looks like it isn’t possible:

n8n-io/n8n/blob/71cae90679d9d6fe4cf0dc898827cc9cd4457873/packages/nodes-base/nodes/Kafka/Kafka.node.ts#L357


      
          					if (values !== undefined) {
          						for (const value of values) {
          							//@ts-ignore
          							headers[value.key] = value.value;
          						}
          					}
          				}
          
          
				topicMessages.push({
          					topic,
          					messages: [
          						{
          							value: message,
          							headers,
          						},
          					],
          				});
          			}
          
          
			responseData = await producer.sendBatch({
          				topicMessages,

marcus · September 27, 2022, 8:38am

Hey @jbacklund,
I am sorry to say but it looks like our current Kafka node implementation does not support message keys. I converted your question to a feature request. Make sure to upvote it yourself.

jbacklund · September 27, 2022, 9:36am

Thanks for the response. I have created a PR with a fix.

jan · October 14, 2022, 8:43am

Got released with [email protected]