apache-pulsar - Apache Pulsar Java 客户端占用过多内存 (OOM)

Question

我用 Spring boot 编写了一个简单的 Apache Pulsar 客户端——一个初始化为 bean 的 pulsar-producer，它将在 rest controller 中用于将传入的 api 消息发布到 Pulsar，以及一个消费消息的消费者，在控制台打印一些值 &承认。

截至目前，该应用程序非常简单，但在加载此 spring-boot 应用程序的那一刻，我发现内存达到峰值，有时会出现 OOM。 Pulsar 客户端配合 Spring-boot 使用时有什么具体配置吗？

大部分代码是 Pulsar 文档中找到的代码。

Answer 1

我回答这个问题是为了记录这个问题 - 不要使用循环来消费消息，而是采用通过

订阅消费者的 MessageListener

consumer.messageListener(new Myconsumer())

或

consumer.messageListener((consumer, msg)->{//do something})

Docs 没有提到这个，但是我发现了 surfing the consumer api。