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

Add configuration to support bounded queue #484

Closed
subkanthi opened this issue Mar 1, 2024 · 0 comments · Fixed by #491
Closed

Add configuration to support bounded queue #484

subkanthi opened this issue Mar 1, 2024 · 0 comments · Fixed by #491
Labels
lightweight Issues related to Lightweight version qa-verified label to mark issues that were verified by QA

Comments

@subkanthi
Copy link
Collaborator

Currently a ConcurrentLinkedQueue is used as a conduit between debezium/kafka connect and the thread pool(which create DB connections, transform data and persist data).
It will be good to provide an option to the user to have a bounded queue and apply backpressure on Debezium event loop.
This will address only the lightweight version.
@subkanthi subkanthi added 2.0.2 and removed 2.0.2 labels Mar 1, 2024
@subkanthi subkanthi linked a pull request Mar 6, 2024 that will close this issue
Changed from ConcurrentLinkedQueue to LinkedBlockedQueue with the size configurable #491
Merged
@subkanthi subkanthi added the lightweight Issues related to Lightweight version label Mar 8, 2024
@subkanthi subkanthi mentioned this issue Mar 8, 2024
Closed
@Selfeer Selfeer added the qa-verified label to mark issues that were verified by QA label Mar 18, 2024
@svb-alt svb-alt added this to the 2.1.0 milestone Apr 4, 2024
@subkanthi subkanthi removed this from the 2.1.0 milestone Apr 5, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
lightweight Issues related to Lightweight version qa-verified label to mark issues that were verified by QA
Projects
None yet
Milestone
No milestone
3 participants
@subkanthi @Selfeer @svb-alt