Shovel duplicates exchange messages for each node in RabbitMQ Cluster since 3.8.16 #3132
-
Hi you'all 👋 I'm running into Problems with the Shovel plugin since upgrading RabbitMQ from 3.8.15 to 3.8.16. I found a similar report (#3065), but for 3.8.14 where it was definitely working fine on our clusters so I'm opening this as a new discussion. I can't anything in the changelog which sounds like it could cause this problem, anybody have any ideas? Shovel StatusShovel status in 3.8.15Shovel status in 3.8.16Message RateThe Message rate of the exchange should be around 110 - 130 messages/s Message Rate in 3.8.15Message Rate in 3.8.16ConfigurationWe deploy the Shovel via a definition file: {
"users": [
{
"name": "shovel",
"password_hash": "",
"hashing_algorithm": "rabbit_password_hashing_sha256",
"tags": "",
"limits": {}
}
],
"vhosts": [
{
"name": "/"
}
],
"permissions": [
{
"user": "shovel",
"vhost": "/",
"configure": ".*",
"write": ".*",
"read": ".*"
}
],
"topic_permissions": [],
"parameters": [
{
"value": {
"ack-mode": "no-ack",
"dest-add-forward-headers": false,
"dest-exchange": "vessel_positions",
"dest-protocol": "amqp091",
"dest-uri": "amqps://broker-playground.example.com?cacertfile=/etc/destination-ca.cert.pem&certfile=/etc/destination.cert.pem&keyfile=/etc/destination.key.pem&verify=verify_peer&fail_if_no_peer_cert=true&auth_mechanism=external",
"src-delete-after": "never",
"src-exchange": "vessel_positions",
"src-exchange-key": "#",
"src-prefetch-count": 100,
"src-protocol": "amqp091",
"src-uri": "amqps://broker.example.com?cacertfile=/etc/source-ca.cert.pem&certfile=/etc/source.cert.pem&keyfile=/etc/source.key.pem&verify=verify_peer&fail_if_no_peer_cert=true&auth_mechanism=external"
},
"vhost": "/",
"component": "shovel",
"name": "shovel"
}
],
"exchanges": [
{
"name": "vessel_positions",
"vhost": "/",
"type": "topic",
"durable": true,
"auto_delete": false,
"internal": false,
"arguments": {}
}
]
} |
Beta Was this translation helpful? Give feedback.
Replies: 1 comment 1 reply
-
Moved to #3154 and hopefully answered there. |
Beta Was this translation helpful? Give feedback.
Moved to #3154 and hopefully answered there.