private void pushMessage(String topic, byte[] message) {
    try (Producer<byte[]> producer = pulsarClient.newProducer().topic(topic).create()) {
      producer.newMessage().value(message).send();
    } catch (PulsarClientException e) {
      throw new RuntimeException("Unable to send message to Pulsar", e);
    }
  }
Guards against errors that leak from storage, such as InvalidQueryException
zipkin-collector/pulsar/src/test/java/zipkin2/collector/pulsar/ITPulsarCollector.java