[Questions] [No details to work with] quorum queue consumer cannot be recovered #12660
-
Community Support Policy
RabbitMQ version used3.13.6 Erlang version used26.2.x Operating system (distribution) usedlinux How is RabbitMQ deployed?Generic binary package rabbitmq-diagnostics status outputSee https://www.rabbitmq.com/docs/cli to learn how to use rabbitmq-diagnostics Logs from node 1 (with sensitive values edited out)See https://www.rabbitmq.com/docs/logging to learn how to collect logs
Logs from node 2 (if applicable, with sensitive values edited out)See https://www.rabbitmq.com/docs/logging to learn how to collect logs
Logs from node 3 (if applicable, with sensitive values edited out)See https://www.rabbitmq.com/docs/logging to learn how to collect logs
rabbitmq.confSee https://www.rabbitmq.com/docs/configure#config-location to learn how to find rabbitmq.conf file location
Steps to deploy RabbitMQ clusterRabbitMQ cluster with three nodes. Steps to reproduce the behavior in questionAfter the data disk permission of one RabbitMQ is changed to 000, RabbitMQ crashes and consumers in the arbitration queue do not automatically recover. advanced.configSee https://www.rabbitmq.com/docs/configure#config-location to learn how to find advanced.config file location
Application code# PASTE CODE HERE, BETWEEN BACKTICKS Kubernetes deployment file# Relevant parts of K8S deployment that demonstrate how RabbitMQ is deployed
# PASTE YAML HERE, BETWEEN BACKTICKS What problem are you trying to solve?We use the Java client, where the automatic recovery of the client is disabled, and we actively listen to the connection and channel shutdown events. When an exception is triggered, the server crashes occasionally and does not notify the client of the shutdown event. As a result, the client does not recover automatically. I added some logs to the server, and the consumer was always deleted by a strange channel, which was not the channel that created the consumer. |
Beta Was this translation helpful? Give feedback.
Replies: 1 comment
-
@dormanze look at you, first ticked the box saying that you will provide all relevant information and ended up providing next to nothing relevant. Do you think we are asking for those logs for the kicks of it? Should on top of that we guess what does "server crashes" means, e.g. what exception the node logs? In any case, 3.13 is out of community support. Try against against |
Beta Was this translation helpful? Give feedback.
@dormanze look at you, first ticked the box saying that you will provide all relevant information and ended up providing next to nothing relevant. Do you think we are asking for those logs for the kicks of it? Should on top of that we guess what does "server crashes" means, e.g. what exception the node logs?
In any case, 3.13 is out of community support. Try against against
4.0.3
and provide all logs and more detailed descriptions this time around.