Page History

...

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

2. Create a Header class 

   1. Add a String key field to Header class

   2. Add a byte[] value field to Header class

3. Create a Headers class 
   

   1. Add a headers (Header[]) field to Headers class

   2. Add accessor methods on the Headers class - void add(String, byte[]Header) and a Collection<byte[]> get(String)
   3. implement Iterable<Header>

4. Add a headers field to ProducerRecord and ConsumerRecord. 

5. Add accessor methods on the Producer/ConsumerRecord Headers getHeaders()
   1. Add ProduceRequest/ProduceResponse V4 which uses the new message format.
6. Add FetchRequest/FetchResponse V4 which uses the new message format.
7. The serialisation of the [String, byte[]] header array will on the wire using a strict format
8. Each headers value will be custom serialisable by the interceptors/plugins that use the header.

...