org.apache.kafka.clients.consumer.ConsumerRecord to org.apache.kafka.common.header.Headers