Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

GH-2823: Messages routed to the wrong consumer #2825

Merged
merged 1 commit into from
Sep 29, 2023
Merged

GH-2823: Messages routed to the wrong consumer #2825

merged 1 commit into from
Sep 29, 2023

Conversation

sobychacko
Copy link
Contributor

@sobychacko sobychacko commented Sep 29, 2023 •
edited
Loading

  • When event-type routing is enabled in Kafka Streams binder and conurrency > 1 is used, messages are occasionally getting dispatched to the wrong consumer causing CCE. This is due to a race condition caused by a shared resource across threads. Fixing the issue by introducing a ThreadLocal variable.

Resolves #2823

@sobychacko
spring-cloudGH-2823: Messages routed to the wrong consumer
30b85ce 
 - When event-type routing is enabled in Kafka Streams binder
   and conurrency > 1 is used, messages are occasionally getting
   dispatched to the wrong consumer causing CCE. This is due
   to a race condition caused by a shared resource across threads.
   Fixing the issue by introducing a ThreadLocal variable.

Resolves spring-cloud#2823
@sobychacko sobychacko merged commit 5ea391b into spring-cloud:main Sep 29, 2023
1 check passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers
No reviews
Assignees
No one assigned
Labels
Backport 4.0.x
Projects
None yet
Milestone
No milestone
1 participant
@sobychacko