Skip to content

Conversation

Gsantomaggio
Copy link
Member

@Gsantomaggio Gsantomaggio commented Jun 26, 2025

Add Consumer Flow control.
Configure the way to request the credits with the following parameters:

public enum ConsumerFlowStrategy
{
    CreditsBeforeParseChunk,
    CreditsAfterParseChunk,
    ConsumerCredits
}
var consumerConfig = new RawConsumerConfig(stream)
 {
     FlowControl = new FlowControl() { 
        Strategy = ConsumerFlowStrategy.CreditsBeforeParseChunk
     },

Add rawConsumer.Credits to manually request Credits

Closes #420

Signed-off-by: Gabriele Santomaggio <[email protected]>
lock scope

Signed-off-by: Gabriele Santomaggio <[email protected]>
Signed-off-by: Gabriele Santomaggio <[email protected]>
Signed-off-by: Gabriele Santomaggio <[email protected]>
Signed-off-by: Gabriele Santomaggio <[email protected]>
@Gsantomaggio Gsantomaggio added this to the 1.8.15 milestone Jun 30, 2025
Signed-off-by: Gabriele Santomaggio <[email protected]>
Signed-off-by: Gabriele Santomaggio <[email protected]>
@Gsantomaggio Gsantomaggio marked this pull request as ready for review June 30, 2025 19:32
Signed-off-by: Gabriele Santomaggio <[email protected]>
@Gsantomaggio Gsantomaggio merged commit 4f13639 into main Jun 30, 2025
2 checks passed
@Gsantomaggio Gsantomaggio deleted the credit_flow_control branch June 30, 2025 20:21
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Implement Consumer Flow Strategy
1 participant