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

Question

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

到目前为止，该应用程序非常简单，但是在加载此 spring-boot 应用程序的那一刻，我看到了内存峰值，有时会出现 OOM。将 Pulsar 客户端与 Spring-boot 一起使用时，是否需要使用任何特定配置？

该代码主要是在 Pulsar 文档中找到的代码。

Answer 1

我正在回答这个来记录这个问题 -不要使用循环来消费消息，而是通过MessageListener订阅消费者

consumer.messageListener(new Myconsumer())

或者

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

文档没有提到这一点，但我发现浏览消费者 api。