@Test public void nextSpan_should_not_clear_other_headers() {

  consumerRecord.headers().add("foo", new byte[0]);
  kafkaTracing.nextSpan(consumerRecord);
  assertThat(consumerRecord.headers().headers("foo")).isNotEmpty();
}