为了解决Pulsar的存储写入延迟与发布延迟之间的问题，可以使用以下代码进行优化。

一种常见的优化方式是使用异步生产者来减少发布速度与存储写入速度之间的延迟差异。 异步生产者会通过将消息缓存在本地缓冲区中来最小化延迟，然后再当可以将消息成功发送到Pulsar集群时再将其发送。 实际上，异步生产者的成功率和吞吐量都要更高。

以下代码演示了如何使用Pulsar异步生产者：

Producer producer = client.newProducer()
                                .topic(topicName)
                                .producerName("producer-name")
                                .batchingMaxPublishDelay(10, TimeUnit.MILLISECONDS)
                                .async()
                                .create();

producer.sendAsync(message).thenAccept(messageId -> {
    System.out.printf("Message with ID %s successfully sent", messageId);
}).exceptionally(ex -> {
    System.err.printf("Failed to send message: %s", ex.getMessage());
});

此代码使用异步生产者来发送消息。 每次调用sendAsync方法时，消息将被异步发送。 代码还演示了如何处理由Pulsar集群发送的消息ID。

通过使用异步生产者，发布速度与存储写入速度之间的延迟差异将最小化，从而提高Pulsar的性能和可靠性。