@Test public void nextSpan_should_retain_baggage_headers() {

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