Message timestamps as in KIP-32 - Githubissues

oleksiyk / kafka

Apache Kafka 0.9 client for Node

MIT License

297 stars 85 forks source link

Message timestamps as in KIP-32 #228

Open alexeevg opened 6 years ago

alexeevg commented 6 years ago

Hi, are there plans to add support for message timestamps, implemented in Kafka 0.10 and described in https://cwiki.apache.org/confluence/display/KAFKA/KIP-32+-+Add+timestamps+to+Kafka+message ?

It boils down to

adding a timestamp field to Message format and bumping MagicByte to 1 (see details)
adding ProduceRequest/ProduceResponse V2 and FetchRequest/FetchResponse V2 (see details)