SOHU-Co / kafka-node

Node.js client for Apache Kafka 0.8 and later.
MIT License
2.66k stars 627 forks source link

The kafka-node has not supported the header feature yet. #1309

Open yunnysunny opened 5 years ago

yunnysunny commented 5 years ago

Kafka has add the feature of header from version 0.11.x, but kafka-node has not supported it. Do you have any plan to implement that?

https://cwiki.apache.org/confluence/display/KAFKA/KIP-82+-+Add+Record+Headers

Freakachoo commented 5 years ago

Also needed. Please

vincenzo commented 4 years ago

Use https://www.npmjs.com/package/kafkajs

ddoice commented 4 years ago

IMO this is a must if you want to implement some kind of leaky bucket pattern to use the headers without changing the original message.

I would love to use kafka-node because kafkajs have some problems with consumers using the same groupId but different topics.

anchit93 commented 4 years ago

Is there any update on this feature ? I am also using kafka-node package in my application and wanted to utilize message headers

nhogan5 commented 3 years ago

Please add this. Im going to have to switch packages without this.

al3xis01 commented 1 year ago

What about this features ?

wrgtorres commented 11 months ago

any update?