Gabriele Santomaggio
Gabriele Santomaggio
Given a cluster 3 nodes cluster running : - `rabbitmq v3.9 latest` and with ~500 consumers - cpu: 2 memory: 16Gi `rabbitmq-streams list_stream_consumers` doesn't work in the right way. ```...
Improve the `rabbitmq-streams` messages, in this case for example the replica is already in progress for another node, but it is not totally clear for the user. ```shell Adding a...
It shows how to use the stream queue with the AMQP client. See: - https://www.rabbitmq.com/stream.html - https://blog.rabbitmq.com/posts/2021/07/rabbitmq-streams-overview
I am opening this issue after a conversation with @lukebakken [here the thread](https://groups.google.com/d/msg/rabbitmq-users/Sks6AF0x0wk/YwNDvALSAgAJ) # RabbitMQ test with different libraries I made a few tests with different client libraries. ### Environment:...
This issue is a: [ ] Bug Report [x] Enhancement suggestion [ ] Feature request About RabbitMQ you can use the rabbitmq operator: https://www.rabbitmq.com/kubernetes/operator/operator-overview.html Currently, civo installation exposes the standard...
Hi all, I'd need to integrate my network filter with RBAC. I saw that standard filters use [`setDynamicMetadata`](https://github.com/envoyproxy/envoy/blob/main/source/extensions/filters/network/postgres_proxy/postgres_filter.cc#L186) to emit the metadata. I am looking for something similar in the...
need to invalidate [unconfirmed messages](https://github.com/rabbitmq/rabbitmq-stream-go-client/blob/main/pkg/stream/producer.go#L22) a the moment the list in oubouded.
Ref https://github.com/rabbitmq/rabbitmq-server/pull/5321 Per [internal conversion](https://vmware.slack.com/archives/C039S4USVPG/p1659086921580689)
Implement the Single-Active Consumer feature. Java reference: https://rabbitmq.github.io/rabbitmq-stream-java-client/sac/htmlsingle/#single-active-consumer Single Active Consumer requires RabbitMQ 3.11 or more.
Make `frame_size` configurable. At the moment it uses the default configuration