Page History

...

1. Add a new headers length and value (byte[]) to the core message format.

2. Add a headers (Map<int, byte[]>) field to ProducerRecord and ConsumerRecord. 

3. Add accessor methods on the Producer/ConsumerRecord void setHeader(int, byte[]) and a byte[] getHeader(int)
4. Add ProduceRequest/ProduceResponse V3 which V4 which uses the new message format.
5. Add FetchRequest/FetchResponse V3 V4 which uses the new message format.
6. The serialisation of the [int, bye[]] header set will on the wire using a strict format
7. Each headers value will be custom serialisable by the interceptors/plugins that use the header.
8. As int key based headers for compactness ranges will be reserved for different usages:
   1. client headers adopted by the kafka open source (not necessary the kafka open source owns it)
   2. broker headers adopted by the kafka open source (not necessary the kafka open source owns it)
   3. commercial vendor space
   4. custom inhouse

...