0
I Use This!
Moderate Activity

Commits : Listings

Analyzed about 14 hours ago. based on code collected about 14 hours ago.
Aug 08, 2024 — Aug 08, 2025
Commit Message Contributor Files Modified Lines Added Lines Removed Code Location Date
Add synchronized decorator; add lock to subscription state (#2636) More... 2 months ago
Update build links in documentation (#2634) More... 3 months ago
Patch Release 2.2.10 More... 3 months ago
Pass host as kwarg to get_sasl_mechanism More... 3 months ago
Set the current host in the SASL configs (#2633) More... 3 months ago
Fix sasl gssapi plugin: do not rely on client_ctx.complete in auth_bytes() (#2631) More... 3 months ago
Patch Release 2.2.9 More... 3 months ago
More / updated debug logging for coordinator / consumer (#2630) More... 3 months ago
Do not reset fetch positions if offset commit fetch times out (#2629) More... 3 months ago
Patch Release 2.2.8 More... 3 months ago
Dont mark coordinator dead on ThrottlingQuotaExceededError More... 3 months ago
Fix timeout seconds error message in KafkaProducer (#2627) More... 3 months ago
Log all SyncGroupResponse errors as info+ More... 3 months ago
More coordinator / heartbeat logging (#2621) More... 3 months ago
Update offset commit error handling; use RebalanceInProgressError if applicable (#2623) More... 3 months ago
Wait for next heartbeat in thread loop; check for connected coordinator (#2622) More... 3 months ago
Acquire client lock in heartbeat thread before sending requests (#2620) More... 3 months ago
Patch Release 2.2.7 More... 3 months ago
Minor Heartbeat updates: catch more exceptions / log configuration / raise KafkaConfigurationError (#2618) More... 3 months ago
Patch Release 2.2.6 More... 3 months ago
Only disable heartbeat thread once at beginning of join-group (#2617) More... 3 months ago
Patch Release 2.2.5 More... 3 months ago
Fix producer busy loop with no pending batches (#2616) More... 3 months ago
Fixup py27 fetcher test failure More... 3 months ago
Bump version for development More... 3 months ago
Patch Release 2.2.4 More... 3 months ago
Do not reset_generation after RebalanceInProgressError; improve CommitFailed error messages (#2614) More... 3 months ago
Fix KafkaConsumer.poll() with zero timeout (#2613) More... 3 months ago
Fix Fetch._reset_offsets_async() KeyError when fetching from multiple nodes (#2612) More... 3 months ago
Update changes w/ 2.1.6 backport release More... 3 months ago