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

Prioritize non-message ops/callbacks #1088

Closed
edenhill opened this issue Mar 2, 2017 · 0 comments
Closed

Prioritize non-message ops/callbacks #1088

edenhill opened this issue Mar 2, 2017 · 0 comments
Milestone
0.9.5

Comments

@edenhill
Copy link
Contributor

edenhill commented Mar 2, 2017

stats, etc, should be prioritized in front of message ops on the consumer queue for the case where message processing is slow (since callbacks would have to wait for all prefetched messages to be processed.

See confluentinc/confluent-kafka-python#138
@edenhill edenhill modified the milestone: 0.9.5 Mar 3, 2017
edenhill added a commit that referenced this issue Mar 9, 2017
@edenhill
Added op priority to queues (for #1088)
3e4ccaf
edenhill added a commit that referenced this issue Mar 10, 2017
@edenhill
Prioritize all relevant user-facing ops (callbacks) (#1088)
a4d1af0
edenhill added a commit that referenced this issue Apr 7, 2017
@edenhill
Added op priority to queues (for #1088)
9e01c1d 
(cherry picked from commit 3e4ccaf)
edenhill added a commit that referenced this issue Apr 7, 2017
@edenhill
Prioritize commit_cb over messages on poll queue (closes #1088)
40b848d 
(cherry picked from commit eca37e1)
edenhill added a commit that referenced this issue Apr 7, 2017
@edenhill
Prioritize all relevant user-facing ops (callbacks) (#1088)
37ff1c6 
(cherry picked from commit a4d1af0)
@edenhill edenhill modified the milestones: next feature, 0.9.5 Apr 19, 2017
larry-cdn77 added a commit to larry-cdn77/librdkafka that referenced this issue Jan 31, 2022
@larry-cdn77
Modify confluentinc#1088 so that prioritised broker wake-ups are enqu…
11e3b1b 
…eued to head without sorting in an attempt to address confluentinc#3692
@larry-cdn77 larry-cdn77 mentioned this issue Feb 6, 2022
Open
7 tasks
larry-cdn77 added a commit to cdn77/librdkafka that referenced this issue Feb 8, 2022
@larry-cdn77
Insert prioritised wake-ups to head of broker operations queue
af44ba8 
See also:

confluentinc#1088
confluentinc#3692
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
0.9.5
Development

No branches or pull requests
1 participant
@edenhill