重新启动时，我在消费者方面遇到了问题。在转储堆并筛选线程后，我确定问题是由于 kahadb 本地存储库索引文件的压缩造成的。随着此文件变大，消费者再次开始获取消息所需的时间也会增加。我已经删除了我的本地存储库目录，重新启动并验证了消费者几乎可以立即收到消息。
有人在使用 ActiveMQ 和 KahaDB 时遇到过这个问题吗？有时，如果目录没有被清除，我的消费者可能需要长达 1.5 小时才能再次开始从代理获取消息。
我还验证了消息是及时发布的，它们只是没有被消费，因为索引压缩线程阻塞了“添加”线程。
任何见解将不胜感激！