@Test public void nextSpan_should_tag_topic_and_key_when_no_incoming_context() {

  kafkaTracing.nextSpan(consumerRecord).start().finish();
  assertThat(spans.get(0).tags())
    .containsOnly(entry("kafka.topic", TEST_TOPIC), entry("kafka.key", TEST_KEY));
}