@Test public void nextSpan_should_clear_propagation_headers() {

  addB3MultiHeaders(parent, consumerRecord);
  kafkaTracing.nextSpan(consumerRecord);
  assertThat(consumerRecord.headers().toArray()).isEmpty();
}