@Test
public void nextSpan_should_create_span_if_no_headers() {

  ProcessorContext fakeProcessorContext = processorContextSupplier.apply(new RecordHeaders());
  assertThat(kafkaStreamsTracing.nextSpan(fakeProcessorContext)).isNotNull();
}