private void messageWithMultipleSpans(SpanBytesEncoder encoder) throws Exception {
    byte[] message = encoder.encodeList(spans);
    pushMessage(collector.topic, message);

    assertThat(receivedSpans.take()).containsAll(spans);
    assertThat(pulsarMetrics.messages()).isEqualTo(1);
    assertThat(pulsarMetrics.messagesDropped()).isZero();
    assertThat(pulsarMetrics.bytes()).isEqualTo(message.length);
    assertThat(pulsarMetrics.spans()).isEqualTo(spans.size());
    assertThat(pulsarMetrics.spansDropped()).isZero();
  }
Guards against errors that leak from storage, such as InvalidQueryException
zipkin-collector/pulsar/src/test/java/zipkin2/collector/pulsar/ITPulsarCollector.java