我正在使用activemq。KahaDB是activemq的默认消息库。但它的大小不断增加,最终耗尽了磁盘空间。即使所有消息都得到确认,它仍然会增大大小,并在其数据存储中不断创建新的日志文件。
我没有设置与KahaDB相关的属性,它使用的是默认属性。
broker = new BrokerService();
TransportConnector connector = new TransportConnector();
connector.setUri(new URI("tcp://localhost:61616"));
broker.addConnector(connector);
broker.start();这些是我在broker上设置的唯一属性。有人能告诉我我可以在KahaDB上使用哪些属性来避免这个错误吗?
发布于 2017-10-23 04:21:22
KahaDB日志和索引文件存在的原因有很多,其中一些原因并不总是很明显,因此您需要进行一些调试,看看是什么在保留日志文件,它可以像保存整个日志文件的一条未确认消息一样简单,在某些情况下,未来的日志文件会跟踪该日志中其他消息的acks。
ActiveMQ站点上有一个很好的article来研究这个问题,这样您就可以看到您的案例中有什么,使日志中的内容保持活动状态。使用最新的发行版也是一个好主意,因为在此过程中会修复一些问题,以防止日志在不应该出现的时候滞留。
https://stackoverflow.com/questions/46869733
复制相似问题