@Test public void nextSpan_should_create_span_with_baggage() {

  addB3MultiHeaders(parent, consumerRecord);
  consumerRecord.headers().add(BAGGAGE_FIELD_KEY, "user1".getBytes());
  Span span = kafkaTracing.nextSpan(consumerRecord);
  assertThat(BAGGAGE_FIELD.getValue(span.context())).contains("user1");
}