kafka
kafka copied to clipboard
Message timestamps as in KIP-32
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)