Commits

Commits on Jun 1, 2025

Add synchronized decorator; add lock to subscription state (#2636)
dpkp
authored
e6abbbf
Copy full SHA for e6abbbf

Commits on May 24, 2025

Update build links in documentation (#2634)
boidolr
authored
5957c1b
Copy full SHA for 5957c1b

Commits on May 22, 2025

Patch Release 2.2.10
dpkp
committed
6583460
Copy full SHA for 6583460
Pass host as kwarg to get_sasl_mechanism
dpkp
committed
7fceb1b
Copy full SHA for 7fceb1b
Set the current host in the SASL configs (#2633)
Show description for e2b6693

SeppMe
and
SMeinhardt
authored
e2b6693
Copy full SHA for e2b6693
Fix sasl gssapi plugin: do not rely on client_ctx.complete in auth_bytes() (#2631)
dpkp
authored
7b7f3af
Copy full SHA for 7b7f3af

Commits on May 21, 2025

Patch Release 2.2.9
dpkp
committed
48dd596
Copy full SHA for 48dd596
More / updated debug logging for coordinator / consumer (#2630)
dpkp
authored
bd21713
Copy full SHA for bd21713
Do not reset fetch positions if offset commit fetch times out (#2629)
dpkp
authored
3463f59
Copy full SHA for 3463f59
Patch Release 2.2.8
dpkp
committed
bcbd1b7
Copy full SHA for bcbd1b7
Dont mark coordinator dead on ThrottlingQuotaExceededError
dpkp
committed
95c2f3a
Copy full SHA for 95c2f3a
Fix timeout seconds error message in KafkaProducer (#2627)
dpkp
authored
62a7d80
Copy full SHA for 62a7d80

Commits on May 15, 2025

Log all SyncGroupResponse errors as info+
dpkp
committed
452e354
Copy full SHA for 452e354
More coordinator / heartbeat logging (#2621)
dpkp
authored
5de666a
Copy full SHA for 5de666a
Update offset commit error handling; use RebalanceInProgressError if applicable (#2623)
dpkp
authored
8f77cc8
Copy full SHA for 8f77cc8
Wait for next heartbeat in thread loop; check for connected coordinator (#2622)
dpkp
authored
2f95590
Copy full SHA for 2f95590
Acquire client lock in heartbeat thread before sending requests (#2620)
dpkp
authored
8a424e9
Copy full SHA for 8a424e9

Commits on May 13, 2025

Patch Release 2.2.7
dpkp
committed
00a5e6c
Copy full SHA for 00a5e6c
Minor Heartbeat updates: catch more exceptions / log configuration / raise KafkaConfigurationError (#2618)
dpkp
authored
71c10f4
Copy full SHA for 71c10f4

Commits on May 8, 2025

Patch Release 2.2.6
dpkp
committed
be22ee5
Copy full SHA for be22ee5
Only disable heartbeat thread once at beginning of join-group (#2617)
dpkp
authored
32a9285
Copy full SHA for 32a9285
Patch Release 2.2.5
dpkp
committed
bf77e9a
Copy full SHA for bf77e9a
Fixup py27 fetcher test failure
dpkp
committed
7536bcb
Copy full SHA for 7536bcb
Fix producer busy loop with no pending batches (#2616)
dpkp
authored
590ef93
Copy full SHA for 590ef93

Commits on May 4, 2025

Bump version for development
dpkp
committed
fef828f
Copy full SHA for fef828f
Patch Release 2.2.4
dpkp
committed
d8c9bb1
Copy full SHA for d8c9bb1
Do not reset_generation after RebalanceInProgressError; improve CommitFailed error messages (#2614)
dpkp
authored
d9c2009
Copy full SHA for d9c2009
Fix KafkaConsumer.poll() with zero timeout (#2613)
dpkp
authored
2f282eb
Copy full SHA for 2f282eb
Fix Fetch._reset_offsets_async() KeyError when fetching from multiple nodes (#2612)
dpkp
authored
4100319
Copy full SHA for 4100319

Commits on May 2, 2025

Update changes w/ 2.1.6 backport release
dpkp
committed
827832a
Copy full SHA for 827832a

Commits on May 1, 2025

Patch Release 2.2.3
dpkp
committed
2767d14
Copy full SHA for 2767d14
Ignore leading SECURITY_PROTOCOL:// in bootstrap_servers (#2608)
dpkp
authored
cef0ea6
Copy full SHA for cef0ea6
Only create fetch requests for ready nodes (#2607)
dpkp
authored
b6036f2
Copy full SHA for b6036f2

Commits on Apr 30, 2025

Bump version for development
dpkp
committed
26fbd2e
Copy full SHA for 26fbd2e
Patch Release 2.2.2
dpkp
committed
3d31c14
Copy full SHA for 3d31c14