ActiveMQ Artemis слишком долго запускается, когда у него огромные файлы подкачки

Среда:

  • ОС: Убунту 20.04
  • Java: OpenJDK 11.0.12
  • Артемида ActiveMQ: 2.25.0

Мой MQ имеет большие данные, как показано ниже:

root@mdmcs22p:~# du -h -d 1 /data/artemis/data
4.4G    /data/artemis/data/large-messages
104G    /data/artemis/data/journal
2.1M    /data/artemis/data/bindings
500G    /data/artemis/data/paging
608G    /data/artemis/data
root@mdmcs22p:~#

По какой-то причине мне нужно перезапустить его, поэтому я запускаю следующую команду в папке bin брокера:

./artemis-service restart

Через некоторое время Artemis сбрасывает некоторые журналы исключений. В конце концов, он по-прежнему завершает действие запуска.

Это исключение имеет значение? И как дать Artemis больше времени для запуска JournalStorageManager без этого исключения?

2022-09-30 06:06:30,680 WARN  [org.apache.activemq.artemis.core.server] AMQ222166: No Expiry Address configured for queue mdms.lpr.kma in AddressSettings
2022-09-30 06:06:30,681 WARN  [org.apache.activemq.artemis.core.server] AMQ222165: No Dead Letter Address configured for queue mdms.lpi.bduser in AddressSettings
2022-09-30 06:06:30,681 WARN  [org.apache.activemq.artemis.core.server] AMQ222166: No Expiry Address configured for queue mdms.lpi.bduser in AddressSettings
2022-09-30 06:06:30,681 WARN  [org.apache.activemq.artemis.core.server] AMQ222165: No Dead Letter Address configured for queue mdms.lpr.sadms in AddressSettings
2022-09-30 06:06:30,682 WARN  [org.apache.activemq.artemis.core.server] AMQ222166: No Expiry Address configured for queue mdms.lpr.sadms in AddressSettings
2022-09-30 06:06:30,682 WARN  [org.apache.activemq.artemis.core.server] AMQ222165: No Dead Letter Address configured for queue mdms.lpi.edwh in AddressSettings
2022-09-30 06:06:30,682 WARN  [org.apache.activemq.artemis.core.server] AMQ222166: No Expiry Address configured for queue mdms.lpi.edwh in AddressSettings
2022-09-30 06:09:30,003 WARN  [org.apache.activemq.artemis.utils.critical.CriticalMeasure] Component org.apache.activemq.artemis.core.persistence.impl.journal.JournalStorageManager is expired on path 0
2022-09-30 06:09:30,004 WARN  [org.apache.activemq.artemis.core.server] AMQ224116: The component org.apache.activemq.artemis.core.persistence.impl.journal.JournalStorageManager@219f4597 is not responsive during start up. The Server may be taking too long to start
2022-09-30 06:09:30,816 WARN  [org.apache.activemq.artemis.core.server] AMQ222199: Thread dump: *******************************************************************************
Complete Thread dump
"main" Id=1 RUNNABLE
        at org.apache.activemq.artemis.core.journal.impl.JournalImpl.readJournalFile(JournalImpl.java:612)
        at org.apache.activemq.artemis.core.journal.impl.JournalImpl.load(JournalImpl.java:2136)
        -  locked org.apache.activemq.artemis.core.journal.impl.JournalImpl@36073cbf
        at org.apache.activemq.artemis.core.journal.impl.JournalImpl.load(JournalImpl.java:2429)
        -  locked org.apache.activemq.artemis.core.journal.impl.JournalImpl@36073cbf
        at org.apache.activemq.artemis.core.journal.impl.JournalImpl.load(JournalImpl.java:1739)
        -  locked org.apache.activemq.artemis.core.journal.impl.JournalImpl@36073cbf
        at org.apache.activemq.artemis.core.journal.Journal.load(Journal.java:278)
        at org.apache.activemq.artemis.core.persistence.impl.journal.AbstractJournalStorageManager.loadMessageJournal(AbstractJournalStorageManager.java:908)
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.loadJournals(ActiveMQServerImpl.java:3650)
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.initialisePart2(ActiveMQServerImpl.java:3313)
        -  locked org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl@5930b0c4
        at org.apache.activemq.artemis.core.server.impl.LiveOnlyActivation.run(LiveOnlyActivation.java:76)
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.internalStart(ActiveMQServerImpl.java:671)
        at org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl.start(ActiveMQServerImpl.java:579)
        -  locked org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl@5930b0c4
        at org.apache.activemq.artemis.integration.FileBroker.start(FileBroker.java:64)
        -  locked org.apache.activemq.artemis.integration.FileBroker@3fec39f6
        at org.apache.activemq.artemis.cli.commands.Run.execute(Run.java:127)
        at org.apache.activemq.artemis.cli.Artemis.internalExecute(Artemis.java:160)
        at org.apache.activemq.artemis.cli.Artemis.execute(Artemis.java:108)
        at org.apache.activemq.artemis.cli.Artemis.execute(Artemis.java:135)
        at [email protected]/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at [email protected]/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at [email protected]/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at [email protected]/java.lang.reflect.Method.invoke(Method.java:566)
        at app//org.apache.activemq.artemis.boot.Artemis.execute(Artemis.java:134)
        at app//org.apache.activemq.artemis.boot.Artemis.main(Artemis.java:50)


"Reference Handler" Id=2 RUNNABLE
        at [email protected]/java.lang.ref.Reference.waitForReferencePendingList(Native Method)
        at [email protected]/java.lang.ref.Reference.processPendingReferences(Reference.java:241)
        at [email protected]/java.lang.ref.Reference$ReferenceHandler.run(Reference.java:213)


"Finalizer" Id=3 WAITING on java.lang.ref.ReferenceQueue$Lock@4d2d1b79
        at [email protected]/java.lang.Object.wait(Native Method)
        -  waiting on java.lang.ref.ReferenceQueue$Lock@4d2d1b79
        at [email protected]/java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:155)
        at [email protected]/java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:176)
        at [email protected]/java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:170)
....
....

===============================================================================
End Thread dump
*******************************************************************************

2022-09-30 06:11:42,593 INFO  [org.apache.activemq.artemis.core.server] AMQ221014: 25% loaded


2022-09-30 06:11:53,330 INFO  [org.apache.activemq.artemis.core.server] AMQ221014: 50% loaded
2022-09-30 06:12:01,382 INFO  [org.apache.activemq.artemis.core.server] AMQ221014: 76% loaded
2022-09-30 06:12:11,906 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address DLQ supporting [ANYCAST]
2022-09-30 06:12:11,907 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue DLQ on address DLQ
2022-09-30 06:12:11,912 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address ExpiryQueue supporting [ANYCAST]
2022-09-30 06:12:11,912 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue ExpiryQueue on address ExpiryQueue
2022-09-30 06:12:11,913 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address IT_RECV_QUEUE supporting [ANYCAST]
2022-09-30 06:12:11,913 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue IT_RECV_QUEUE on address IT_RECV_QUEUE
2022-09-30 06:12:11,913 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address IT_SEND_QUEUE supporting [ANYCAST]
2022-09-30 06:12:11,914 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue IT_SEND_QUEUE on address IT_SEND_QUEUE
2022-09-30 06:12:11,914 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address IT_APIC_REQUEST_QUEUE supporting [ANYCAST]
2022-09-30 06:12:11,914 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue IT_APIC_REQUEST_QUEUE on address IT_APIC_REQUEST_QUEUE
2022-09-30 06:12:11,914 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address IT_APIC_RESPONSE_QUEUE supporting [ANYCAST]
2022-09-30 06:12:11,914 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue IT_APIC_RESPONSE_QUEUE on address IT_APIC_RESPONSE_QUEUE
2022-09-30 06:12:11,915 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address OMS.CustnoTransRelation.to.MAM supporting [MULTICAST]
2022-09-30 06:12:11,915 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address OMS.CustnoTransRelationTrans.to.MAM supporting [MULTICAST]
2022-09-30 06:12:11,915 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address OMS.Feeder.to.MAM supporting [MULTICAST]
2022-09-30 06:12:11,915 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address OMS.PlannedOutage.to.MAM supporting [MULTICAST]
2022-09-30 06:12:11,916 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address OMS.PlanOutageStatusChange.to.MAM supporting [MULTICAST]
2022-09-30 06:12:11,916 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address OMS.Transformer.to.MAM supporting [MULTICAST]
2022-09-30 06:12:11,916 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address OMS.OutageRestoreQueryReply.to.STM supporting [MULTICAST]
2022-09-30 06:12:11,916 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address STM.NonPlanOutage.to.OMS supporting [MULTICAST]
2022-09-30 06:12:11,917 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address STM.OutageRestoreQuery.to.OMS supporting [MULTICAST]
2022-09-30 06:12:11,917 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address STM.TransformerOutage.to.OMS supporting [MULTICAST]
2022-09-30 06:12:11,917 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address STM.OutageRestore.to.OMS supporting [MULTICAST]
2022-09-30 06:12:11,917 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpi.all supporting [MULTICAST]
2022-09-30 06:12:11,917 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpi.all_to_ot supporting [MULTICAST]
2022-09-30 06:12:11,917 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpi.dreams supporting [ANYCAST]
2022-09-30 06:12:11,918 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.lpi.dreams on address mdms.lpi.dreams
2022-09-30 06:12:11,918 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpi.bduser supporting [ANYCAST]
2022-09-30 06:12:11,918 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.lpi.bduser on address mdms.lpi.bduser
2022-09-30 06:12:11,918 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpi.edwh supporting [ANYCAST]
2022-09-30 06:12:11,918 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.lpi.edwh on address mdms.lpi.edwh
2022-09-30 06:12:11,919 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpi.bduser2 supporting [ANYCAST]
2022-09-30 06:12:11,919 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.lpi.bduser2 on address mdms.lpi.bduser2
2022-09-30 06:12:11,919 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpi.gems supporting [ANYCAST]
2022-09-30 06:12:11,919 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.lpi.gems on address mdms.lpi.gems
2022-09-30 06:12:11,919 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpi.nbs supporting [ANYCAST]
2022-09-30 06:12:11,920 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.lpi.nbs on address mdms.lpi.nbs
2022-09-30 06:12:11,920 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpi.nbs2 supporting [ANYCAST]
2022-09-30 06:12:11,920 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.lpi.nbs2 on address mdms.lpi.nbs2
2022-09-30 06:12:11,920 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpi.daps supporting [ANYCAST]
2022-09-30 06:12:11,921 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.lpi.daps on address mdms.lpi.daps
2022-09-30 06:12:11,921 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpi.kma supporting [ANYCAST]
2022-09-30 06:12:11,921 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.lpi.kma on address mdms.lpi.kma
2022-09-30 06:12:11,921 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpi.sadms supporting [ANYCAST]
2022-09-30 06:12:11,922 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.lpi.sadms on address mdms.lpi.sadms
2022-09-30 06:12:11,922 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpi.test_it supporting [ANYCAST]
2022-09-30 06:12:11,922 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.lpi.test_it on address mdms.lpi.test_it
2022-09-30 06:12:11,922 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpi.test_ot supporting [ANYCAST]
2022-09-30 06:12:11,923 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.lpi.test_ot on address mdms.lpi.test_ot
2022-09-30 06:12:11,923 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpi.amtfi supporting [ANYCAST]
2022-09-30 06:12:11,923 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.lpi.amtfi on address mdms.lpi.amtfi
2022-09-30 06:12:11,923 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address ttu.sadms supporting [ANYCAST]
2022-09-30 06:12:11,923 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue ttu.sadms on address ttu.sadms
2022-09-30 06:12:11,924 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address fci.sadms supporting [ANYCAST]
2022-09-30 06:12:11,924 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue fci.sadms on address fci.sadms
2022-09-30 06:12:11,924 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpi.sadms supporting [ANYCAST]
2022-09-30 06:12:11,924 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.lpi.sadms on address mdms.lpi.sadms
2022-09-30 06:12:11,925 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.event.sadms supporting [ANYCAST]
2022-09-30 06:12:11,925 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.event.sadms on address mdms.event.sadms
2022-09-30 06:12:11,925 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpr.all supporting [MULTICAST]
2022-09-30 06:12:11,925 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpr.kma supporting [ANYCAST]
2022-09-30 06:12:11,925 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.lpr.kma on address mdms.lpr.kma
2022-09-30 06:12:11,926 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.lpr.sadms supporting [ANYCAST]
2022-09-30 06:12:11,926 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue mdms.lpr.sadms on address mdms.lpr.sadms
2022-09-30 06:12:11,926 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.event.public supporting [MULTICAST]
2022-09-30 06:12:11,926 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.ds.LoadProfile.22.Delivered supporting [MULTICAST]
2022-09-30 06:12:11,926 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.ds.LoadProfile.22.Received supporting [MULTICAST]
2022-09-30 06:12:11,927 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.ds.MeterAssets supporting [MULTICAST]
2022-09-30 06:12:11,927 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address mdms.ds.MeterEvents supporting [MULTICAST]
2022-09-30 06:12:11,927 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address test.TestTopic supporting [MULTICAST]
2022-09-30 06:12:11,927 INFO  [org.apache.activemq.artemis.core.server] AMQ221080: Deploying address test.TestQueue supporting [ANYCAST]
2022-09-30 06:12:11,927 INFO  [org.apache.activemq.artemis.core.server] AMQ221003: Deploying ANYCAST queue test.TestQueue on address test.TestQueue
2022-09-30 06:12:12,241 INFO  [org.apache.activemq.artemis.core.server] AMQ221020: Started EPOLL Acceptor at 192.168.11.64:61616 for protocols [CORE,MQTT,AMQP,STOMP,HORNETQ,OPENWIRE]
2022-09-30 06:12:12,246 INFO  [org.apache.activemq.artemis.core.server] AMQ221020: Started EPOLL Acceptor at 192.168.11.64:5672 for protocols [AMQP]
2022-09-30 06:12:12,250 INFO  [org.apache.activemq.artemis.core.server] AMQ221007: Server is now live
2022-09-30 06:12:12,251 INFO  [org.apache.activemq.artemis.core.server] AMQ221001: Apache ActiveMQ Artemis Message Broker version 2.25.0 [broker_1164, nodeID=f6119a4a-3fc1-11ed-9fe0-00505694e350]
2022-09-30 06:12:12,262 INFO  [org.apache.activemq.artemis] AMQ241003: Starting embedded web server
2022-09-30 06:12:12,562 INFO  [org.apache.activemq.hawtio.branding.PluginContextListener] Initialized activemq-branding plugin
2022-09-30 06:12:12,606 INFO  [org.apache.activemq.hawtio.plugin.PluginContextListener] Initialized artemis-plugin plugin
2022-09-30 06:12:12,858 INFO  [io.hawt.HawtioContextListener] Initialising hawtio services
2022-09-30 06:12:12,870 INFO  [io.hawt.system.ConfigManager] Configuration will be discovered via system properties
2022-09-30 06:12:12,873 INFO  [io.hawt.jmx.JmxTreeWatcher] Welcome to Hawtio 2.15.0
2022-09-30 06:12:12,879 INFO  [io.hawt.web.auth.AuthenticationConfiguration] Starting hawtio authentication filter, JAAS realm: "activemq" authorized role(s): "amq" role principal classes: "org.apache.activemq.artemis.spi.core.security.jaas.RolePrincipal"
2022-09-30 06:12:12,884 INFO  [io.hawt.web.auth.LoginRedirectFilter] Hawtio loginRedirectFilter is using 1800 sec. HttpSession timeout
2022-09-30 06:12:12,895 INFO  [io.hawt.web.proxy.ProxyServlet] Proxy servlet is disabled
2022-09-30 06:12:12,900 INFO  [io.hawt.web.servlets.JolokiaConfiguredAgentServlet] Jolokia overridden property: [key=policyLocation, value=file:/opt/broker_1164/etc/jolokia-access.xml]
2022-09-30 06:12:12,979 INFO  [org.apache.activemq.artemis] AMQ241001: Embedded web server started at http://0.0.0.0:8161
2022-09-30 06:12:12,981 INFO  [org.apache.activemq.artemis] AMQ241002: Artemis Jolokia REST API available at http://0.0.0.0:8161/console/jolokia
2022-09-30 06:12:12,981 INFO  [org.apache.activemq.artemis] AMQ241004: Artemis Console available at http://0.0.0.0:8161/console

Каков ваш вариант использования, который требует наличия такого большого количества данных на диске?

Justin Bertram 30.09.2022 03:30

О, это просто случайность, что потребитель забыл перезапустить, чтобы получать сообщения в течение 4 дней.

wureka 30.09.2022 03:40
Стоит ли изучать PHP в 2023-2024 годах?
Стоит ли изучать PHP в 2023-2024 годах?
Привет всем, сегодня я хочу высказать свои соображения по поводу вопроса, который я уже много раз получал в своем сообществе: "Стоит ли изучать PHP в...
Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией
Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией
В JavaScript одним из самых запутанных понятий является поведение ключевого слова "this" в стрелочной и обычной функциях.
Приемы CSS-макетирования - floats и Flexbox
Приемы CSS-макетирования - floats и Flexbox
Здравствуйте, друзья-студенты! Готовы совершенствовать свои навыки веб-дизайна? Сегодня в нашем путешествии мы рассмотрим приемы CSS-верстки - в...
Тестирование функциональных ngrx-эффектов в Angular 16 с помощью Jest
В системе управления состояниями ngrx, совместимой с Angular 16, появились функциональные эффекты. Это здорово и делает код определенно легче для...
Концепция локализации и ее применение в приложениях React ⚡️
Концепция локализации и ее применение в приложениях React ⚡️
Локализация - это процесс адаптации приложения к различным языкам и культурным требованиям. Это позволяет пользователям получить опыт, соответствующий...
Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
0
2
107
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Если вы знаете, что у вас есть большой журнал, загрузка которого займет много времени, это сообщение WARN и дамп потока не должны вызывать беспокойства. Сообщение WARN выдается критическим анализатором , который отслеживает важные функции брокера и в некоторых случаях выдает сообщения WARN и даже может полностью остановить брокера, если проблема достаточно критична. Как отмечено в документации, вы можете настроить работу критического анализатора. В вашем случае вы можете увеличить critical-analyzer-timeout на broker.xml.

Тем не менее, у вас есть много данных на диске. Брокер предназначен для передачи данных через него. Он не предназначен для хранения данных, как реляционная база данных. Производство и потребление сообщений должны быть относительно сбалансированы, чтобы сообщения не накапливались. Брокер, безусловно, может буферизовать сообщения, если потребление немного отстает, но в конечном итоге потребление должно возобновиться и наверстать упущенное, чтобы устранить любые отставания.

Другие вопросы по теме