I'm running a simple pubsub application in k8s cluster. The publisher and the subscriber are threads in the same process.
The publisher publishes messages to 3 fanout exchanges every 0.5 seconds. Each exchange has 1:1 binding to a queue.
When I scale up the application to 10 pods, I'm observing (not deterministically, but very often) an error unexpected command received returned by Channel.QueueBind(...). After that the management UI shows incorrect binding.
I'm also seeing error operation basic.consume caused a connection exception not_allowed: "attempt to reuse consumer tag in rabbitmq server log at the same time.
I'm running a simple pubsub application in k8s cluster. The publisher and the subscriber are threads in the same process. The publisher publishes messages to 3 fanout exchanges every 0.5 seconds. Each exchange has 1:1 binding to a queue. When I scale up the application to 10 pods, I'm observing (not deterministically, but very often) an error
unexpected command receivedreturned byChannel.QueueBind(...). After that the management UI shows incorrect binding. I'm also seeing erroroperation basic.consume caused a connection exception not_allowed: "attempt to reuse consumer tagin rabbitmq server log at the same time.