@Test
public void nextSpan_should_tag_app_id_and_task_id() {

  ProcessorContext fakeProcessorContext = processorContextSupplier.apply(new RecordHeaders());
  kafkaStreamsTracing.nextSpan(fakeProcessorContext).start().finish();
  assertThat(spans.get(0).tags())
    .containsOnly(
      entry("kafka.streams.application.id", TEST_APPLICATION_ID),
      entry("kafka.streams.task.id", TEST_TASK_ID));
}