### Question:
SnowdropConsumerRecord implements ConsumerRecord<K, V> { @Override public List<Header> headers() { return new LinkedList<>(headers); } SnowdropConsumerRecord(KafkaConsumerRecord<K, V> delegate); @Override String topic(); @Override int partition(); @Override long offset(); @Override long timestamp(); @Override TimestampType timestampType(); @Override K key(); @Override V value(); @Override List<Header> headers(); @Override boolean equals(Object o); @Override int hashCode(); @Override String toString();  }### Answer:
@Test public void shouldGetHeaders() { assertThat(record.headers()).containsOnly( Header.create("h1", "v1"), Header.create("h2", "v2") ); }