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.

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

kafka concurrent access #1282

Open
wants to merge 2 commits into
base: main
Choose a base branch
from

Conversation

bbortt
Copy link
Collaborator

@bbortt bbortt commented Dec 17, 2024

closes #1281.

…a consumer

added a reproducer for citrusframework#1281.
indeed the test which is part of the `KafkaEndpointJavaIT` throws:

```shell
java.util.ConcurrentModificationException: KafkaConsumer is not safe for multi-threaded access. currentThread(name: Thread-1, id: 124) otherThread(id: 125)
```
@bbortt bbortt force-pushed the fix/#1281-kafka-concurrent-access branch from 5c41054 to 1c3db3d Compare December 17, 2024 18:31
@bbortt bbortt requested review from tschlat and christophd and removed request for tschlat December 17, 2024 18:34
@bbortt
Copy link
Collaborator Author

bbortt commented Dec 17, 2024

@bbortt bbortt requested review from tschlat and christophd and removed request for tschlat

ah yea, that makes sense 💃🏼 my clicking is way too fast for GitHub.

@bbortt bbortt force-pushed the fix/#1281-kafka-concurrent-access branch from 1c3db3d to de66a59 Compare December 17, 2024 18:38
@bbortt bbortt added State: Review If pull-request has been opened an is ready/in review and removed State: WIP labels Dec 17, 2024
@bbortt bbortt force-pushed the fix/#1281-kafka-concurrent-access branch from de66a59 to bf69def Compare December 18, 2024 08:32
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Prio: High State: Review If pull-request has been opened an is ready/in review Type: Bug
Projects
None yet
Development

Successfully merging this pull request may close these issues.

KafkaMessageFilteringConsumer#findMessageWithTimeout concurrent access
1 participant