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

Rushidave sync fork to upstream #28

Open
wants to merge 30 commits into
base: rushidave-main-backup-feb-2024
Choose a base branch
from
Open
Changes from 1 commit
Commits
Show all changes
30 commits
Select commit Hold shift + click to select a range
7ac6c6e
Allow disabling thread wakeup in send_request_to_node (#2335)
yzhan289 Mar 2, 2023
f8a7e9b
Transition CI/CD to GitHub Workflows (#2378)
wbarnha Aug 4, 2023
94901bb
Update usage.rst (#2334)
majeeddl Aug 4, 2023
46473ba
docs: Fix a few typos (#2319)
timgates42 Aug 4, 2023
b7a9be6
Update usage.rst (#2308)
athlatif Aug 4, 2023
57d8338
Enable testing for Python 3.12 (#2379)
wbarnha Aug 4, 2023
7e87a01
Add py312 to tox.ini (#2382)
wbarnha Aug 6, 2023
f984984
Update fixtures.py to use "127.0.0.1" for local ports (#2384)
wbarnha Aug 6, 2023
d920108
use isinstance in builtin crc32 (#2329)
FlxB2 Aug 8, 2023
a33fcf4
Update setup.py to install zstandard instead of python-zstandard (#2387)
wbarnha Aug 9, 2023
d894e9a
build: update vendored six from 1.11.0 to 1.16.0 (#2398)
shifqu Nov 2, 2023
779a23c
Bump actions/checkout from 3 to 4 (#2392)
dependabot[bot] Nov 2, 2023
4861bee
Uses assert_called_with instead of called_with (#2375)
Nov 3, 2023
0362b87
Update python-package.yml to expect 3.12 tests to pass and extend exp…
wbarnha Nov 3, 2023
0dbf746
Update setup.py to indicate 3.12 support
wbarnha Nov 3, 2023
38e8d04
Update conn.py to catch OSError in case of failed import (#2407)
wbarnha Nov 3, 2023
a1d268a
Update PYTHON_LATEST in python-package.yml to 3.12
wbarnha Nov 3, 2023
364397c
[FIX] suitablt for the high vresion python. (#2394)
rootlulu Nov 4, 2023
0864817
Update python-package.yml to publish to PyPi for every release (#2381)
wbarnha Nov 7, 2023
43822d0
Bump github/codeql-action from 2 to 3 (#2419)
dependabot[bot] Dec 14, 2023
e9dfaf9
Bump actions/setup-python from 4 to 5 (#2418)
dependabot[bot] Dec 14, 2023
b68f61d
Bump actions/setup-java from 3 to 4 (#2417)
dependabot[bot] Dec 14, 2023
ce7d853
Avoid 100% CPU usage while socket is closed (sleep)
orange-kao Aug 4, 2020
6efff52
Support connecting through SOCKS5 proxies (#2169)
hnousiainen Sep 29, 2020
a927ff2
bugfix: fix infinite loop on KafkaAdminClient (#2194)
hackaugusto Jan 14, 2021
6985761
bugfix: infinite loop when send msgs to controller (#2194)
hackaugusto Jan 14, 2021
4ca2f45
bugfix: race among _connecting and cluster metadata (#2189)
hackaugusto Jan 5, 2021
919f61d
bugfix: raise error in check_version if broker is unavailable
keejon Feb 22, 2024
1a6bf01
Revert "bugfix: raise error in check_version if broker is unavailable"
keejon Feb 26, 2024
c662d94
bugfix: catch KeyError in check_version and retry
keejon Feb 26, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Avoid 100% CPU usage while socket is closed (sleep)
After stop/start kafka service, kafka-python may use 100% CPU caused by
busy-retry while the socket was closed. This fix the issue by sleep 0.1
second if the fd is negative.
  • Loading branch information
orange-kao authored and rushidave committed Feb 28, 2024
commit ce7d853198b4207fa52d6bbf4ef0f5426ae102bf
3 changes: 3 additions & 0 deletions kafka/client_async.py
Original file line number Diff line number Diff line change
@@ -637,6 +637,9 @@ def _poll(self, timeout):
self._sensors.select_time.record((end_select - start_select) * 1000000000)

for key, events in ready:
if key.fileobj.fileno() < 0:
time.sleep(0.1)

if key.fileobj is self._wake_r:
self._clear_wake_fd()
continue