Rocketmq-client не может отправить сообщение потребителю
Я использую клиент rocketmq 4.3.1, теперь у меня возникли некоторые проблемы. Группа потребителей, которая использует его некоторое время, имеет некоторые неиспользованные сообщения. Теперь я новичок в очереди сообщений, потребитель не может использовать ее в обычном режиме, мне нужно перезапустить службу потребителя, чтобы получить сообщение. Но я перешел в группу потребителей, и потребитель может получать сообщение в центре очереди сообщений в режиме реального времени. Я хочу знать причину этой проблемы. Большое спасибо введите описание изображения здесь
Стоит ли изучать PHP в 2026-2027 годах?
Привет всем, сегодня я хочу высказать свои соображения по поводу вопроса, который я уже много раз получал в своем сообществе: "Стоит ли изучать PHP в...
Поведение ключевого слова "this" в стрелочной функции в сравнении с нормальной функцией
В JavaScript одним из самых запутанных понятий является поведение ключевого слова "this" в стрелочной и обычной функциях.
Приемы CSS-макетирования - floats и Flexbox
Здравствуйте, друзья-студенты! Готовы совершенствовать свои навыки веб-дизайна? Сегодня в нашем путешествии мы рассмотрим приемы CSS-верстки - в...
Тестирование функциональных ngrx-эффектов в Angular 16 с помощью Jest
В системе управления состояниями ngrx, совместимой с Angular 16, появились функциональные эффекты. Это здорово и делает код определенно легче для...
Концепция локализации и ее применение в приложениях React ⚡️
Локализация - это процесс адаптации приложения к различным языкам и культурным требованиям. Это позволяет пользователям получить опыт, соответствующий...
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
0
0
162
1
Ответы 1
Я нашел причину, потому что друид, обслуживающий потребителя rocketmq, пытался повторно подключиться к базе данных, в результате чего потребитель больше не получал сообщение.
Другие вопросы по теме
Почему Thread.sleep (0) может предотвратить gc в rocketmq?
MongoDB insertMany или bulkwrite выдает ошибку повторяющегося ключа в Java-API
Какой лучший способ обработать задачу Netty async для HTTP-запроса?
Как установить имя пользователя и пароль, когда я использую кластер в rocketmq?
Неустранимая ошибка rocketmq-cpp LNK1112: тип машины модуля 'x64' конфликтует с типом целевой машины 'X86'
Apache Pulsar против Apache RocketMQ
MessageSelector не может быть разрешен
Как поменять порт rocketmq
Запись байтабуфера отнимает слишком много времени
Не удалось остановить bean-компонент inputBindingLifecycle с Spring Boot 2.1.5, Spring Cloud Stream Greenwich.SR1 и RocketMQ 0.9.0
Похожие вопросы
Можно ли использовать точку / период в названии темы (назначении) ActiveMQ с помощью MQTT
Как следует обрабатывать сбой Apache Pulsar Consumer.acknowledgeAsync ()?
Идентификатор очереди сообщений изменен
Механизм чтения всех сообщений из очереди за один запрос
Camel создает слишком много TCP-соединений (более 15000) в состоянии TIME_WAIT для подключения ActiveMQ
Подход к длительному использованию REST API
Общая переменная изменяется только в одном процессе
Python redis-queue: простой пример из документа не работает
Беззвучно вернуть задание в очередь
POSIX mq_receive не получает правильное значение
Потребитель rocketmq может не иметь отношения к базе данных? Почему вы говорите о db?