Skip to content

kafka.net.selector: use threading.Lock() to detect concurrent access to poll()#2945

Merged
dpkp merged 2 commits intomasterfrom
dpkp/kafka-net-selector-lock
Apr 30, 2026
Merged

kafka.net.selector: use threading.Lock() to detect concurrent access to poll()#2945
dpkp merged 2 commits intomasterfrom
dpkp/kafka-net-selector-lock

Conversation

@dpkp
Copy link
Copy Markdown
Owner

@dpkp dpkp commented Apr 29, 2026

  • fix typo (not sure why pylint missed this)
  • kafka.net.selector: use threading.Lock() to detect concurrent access to poll()

@dpkp dpkp force-pushed the dpkp/kafka-net-selector-lock branch from 1be4c30 to 34c1686 Compare April 30, 2026 00:15
@dpkp dpkp merged commit 944b10e into master Apr 30, 2026
19 checks passed
@dpkp dpkp deleted the dpkp/kafka-net-selector-lock branch April 30, 2026 00:21
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.

1 participant