Skip to content

413 - only process consume errors if decider does not return Directive.Resume - #489

Open
jblackburn21 wants to merge 1 commit into
akkadotnet:devfrom
jblackburn21:413-resuming-consumer-decider
Open

413 - only process consume errors if decider does not return Directive.Resume#489
jblackburn21 wants to merge 1 commit into
akkadotnet:devfrom
jblackburn21:413-resuming-consumer-decider

Conversation

@jblackburn21

Copy link
Copy Markdown

Fixes #413

Changes

Return from ProcessExceptions() in KafkaConsumerActor when decider results in Directive.Resume

Checklist

For significant changes, please ensure that the following have been completed (delete if not relevant):

Latest dev Benchmarks

Include data from the relevant benchmark prior to this change here.

This PR's Benchmarks

Include data from after this change here.

@Aaronontheweb
Aaronontheweb self-requested a review April 6, 2025 21:33
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.

KafkaConsumer.CommittablePartitionedSource sub stream failure

1 participant