@Test
public void nextSpan_uses_current_context() {

  ProcessorContext fakeProcessorContext = processorContextSupplier.apply(new RecordHeaders());
  Span child;
  try (Scope ws = tracing.currentTraceContext().newScope(parent)) {
    child = kafkaStreamsTracing.nextSpan(fakeProcessorContext);
  }
  child.finish();
  assertThat(child.context().parentIdString())
      .isEqualTo(parent.spanIdString());
}