<C extends ProcessingContext> Span nextSpan(C context, Headers headers) {
    TraceContextOrSamplingFlags extracted = extractor.extract(headers);
    // Clear any propagation keys present in the headers
    if (!extracted.equals(emptyExtraction)) {
      clearHeaders(headers);
    }
    Span result = tracer.nextSpan(extracted);
    if (!result.isNoop()) {
      addTags(context, result);
    }
    return result;
  }
@Test void nextSpan_should_create_span_if_no_headers() {
    ProcessorContext<String, String> fakeProcessorContext = processorV2ContextSupplier.get();
    assertThat(kafkaStreamsTracing.nextSpan(fakeProcessorContext, new RecordHeaders())).isNotNull();
  }