How to use Kafka's new headers

Consumer.java

records = consumer.poll(100);

for (ConsumerRecord<String, String> record : records) {

    Headers headers = record.headers();
    headers.forEach((header) -> {
        System.out.println("Header key: " + header.key() +
            " value: " +  new String(header.value(), StandardCharsets.UTF_8));
    });
}

Producer.java

RecordHeader header = new RecordHeader("foo", "bar".getBytes());
Iterable<Header> headers = Collections.singletonList(header);

producer.send(new ProducerRecord<>("topic-name", null, null, null, "message", headers));