Provide way to configure InitialCredit on creation of RawConsumerConfig #264
Closed
bSirotkovic
started this conversation in
Ideas
Replies: 3 comments 3 replies
-
Do you have the same problem with version |
Beta Was this translation helpful? Give feedback.
2 replies
-
@bSirotkovic do you have the opportunity to test #265 ? |
Beta Was this translation helpful? Give feedback.
0 replies
-
Have you considered using the subentry batch send? So you can compress the messages and receive them in a single chunk send. like: var messagesToSend = new List<Message>();
for (ulong i = 0; i < xxxx ; i++)
{
messagesToSend.Add(new Message(new byte[50]));
}
await producer.Send(messagesToSend, CompressionType.Gzip).ConfigureAwait(false); |
Beta Was this translation helpful? Give feedback.
1 reply
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
We've been having serious performance issues with using RMQ Streams when the latency between the broker and the client is high.
We believe the issue is related to the credit flow as described here: https://www.rabbitmq.com/stream.html#consumer-credit-flow
During the creation of
RawConsumerConfig
the subscibe method is called with a hardcoded value of InitialCredit = 2.await _client.Subscribe( _config, InitialCredit, consumerProperties, async deliver => { ... } ).ConfigureAwait(false);
We would like to have an ability to increase this value in
ConsumerConfig
classBeta Was this translation helpful? Give feedback.
All reactions