@Test public void nextSpan_shouldnt_tag_topic_and_key_when_incoming_context() {

  addB3MultiHeaders(parent, consumerRecord);
  kafkaTracing.nextSpan(consumerRecord).start().finish();
  assertThat(spans.get(0).tags())
    .isEmpty();
}