@Test
public void processorSupplier_should_add_baggage_field() {

  ProcessorSupplier<String, String> processorSupplier =
    kafkaStreamsTracing.processor(
      "forward-1", () ->
        new AbstractProcessor<String, String>() {
          @Override
          public void process(String key, String value) {
            assertThat(BAGGAGE_FIELD.getValue(currentTraceContext.get())).isEqualTo("user1");
          }
        });
  Headers headers = new RecordHeaders().add(BAGGAGE_FIELD_KEY, "user1".getBytes());
  Processor<String, String> processor = processorSupplier.get();
  processor.init(processorContextSupplier.apply(headers));
  processor.process(TEST_KEY, TEST_VALUE);
}