Can not supprot stream queue with SAC #134
Replies: 6 comments 1 reply
-
AMQP single active consumer and Stream single active consumer are two different features. To use Stream SAC, you have to use one of the Stream clients that implement the native stream protocol. The bridge of AMQP to Stream does not support this feature. You can read more about Stream SAC here: At the moment, the native stream clients that implement stream SAC and Super Streams are the Java Stream Client and Dotnet Stream Client. |
Beta Was this translation helpful? Give feedback.
-
I'd add that we have the Golang Stream client, but the SAC feature is not ready yet. We are open to contributions btw :) |
Beta Was this translation helpful? Give feedback.
-
|
Beta Was this translation helpful? Give feedback.
-
Please read the documentation about that https://www.rabbitmq.com/stream-core-plugin-comparison.html |
Beta Was this translation helpful? Give feedback.
-
Thanks ! Maybe it not suit for my scenario, I want to create some stream queue and some classic queue |
Beta Was this translation helpful? Give feedback.
-
I will convert this issue to a GitHub discussion. Currently GitHub will automatically close and lock the issue even though your question will be transferred and responded to elsewhere. This is to let you know that we do not intend to ignore this but this is how the current GitHub conversion mechanism makes it seem for the users :( |
Beta Was this translation helpful? Give feedback.
-
I use Rabbitmq3.11.3, and the official say "Single active consumer for streams is a feature available in RabbitMQ 3.11 and more."
but when I use amqp091-go to declare a queue which type is steam,just like this:
queue, err := channel.QueueDeclare(
"q5",
true,
false,
false,
false,
amqp091.Table{
"x-single-active-consumer": true,
"x-queue-type": "stream",
},
)
it always report error: 2022/11/23 16:56:19 Failed to declare a queue: Exception (406) Reason: "PRECONDITION_FAILED - invalid arg 'x-single-active-consumer' for queue 'q5' in vhost '/' of queue type rabbit_stream_queue"
How can I do for it?
Beta Was this translation helpful? Give feedback.
All reactions