0
I Use This!
Moderate Activity

Commits : Listings

Analyzed 1 day ago. based on code collected 1 day ago.
Aug 07, 2024 — Aug 07, 2025
Commit Message Contributor Files Modified Lines Added Lines Removed Code Location Date
Always check for request timeouts (#887) More... over 8 years ago
typo (#883) More... over 8 years ago
Update param in warning (#878) More... over 8 years ago
Remove old design notes from Kafka 8 era (#876) More... over 8 years ago
Fix typos (#874) More... over 8 years ago
Update param in warning More... over 8 years ago
Fix typos More... over 8 years ago
Revert consumer iterators from max_poll_records (#856) More... almost 9 years ago
Fix murmur2 bug handling python2 bytes that do not ascii encode (#815) More... almost 9 years ago
Bugfix on max_poll_records - TypeError: object of type NoneType has no len() More... almost 9 years ago
KAFKA-3007: KafkaConsumer max_poll_records (#831) More... almost 9 years ago
Update Partitioners for use with KafkaProducer (#827) More... almost 9 years ago
Monkeypatch max_in_flight_requests_per_connection when checking broker version (#834) More... almost 9 years ago
Fixup doc references to max_in_flight_requests_per_connection More... almost 9 years ago
Fix message timestamp_type (#828) More... almost 9 years ago
Added ssl_password config option to KafkaProducer class, identical to… (#830) More... almost 9 years ago
from kafka import ConsumerRebalanceListener, OffsetAndMetadata More... almost 9 years ago
When hostname lookup is necessary, do every connect (#812) More... almost 9 years ago
Improve KafkaProducer docstring re retries config More... almost 9 years ago
Fix quota violation exception message (#809) More... almost 9 years ago
Add comment for round robin partitioner with different subscriptions More... almost 9 years ago
Use 0.10.0.1 for integration tests (#803) More... almost 9 years ago
Bump version for development More... almost 9 years ago
Patch Release 1.3.1 More... almost 9 years ago
HOTFIX: Fix BrokerConnectionMetrics when sensors already exist (i.e., on reconnects) (#799) More... almost 9 years ago
Bump version for development More... about 9 years ago
Dump fixture logs on failure More... about 9 years ago
Drain pending requests to the coordinator before initiating group rejoin (#798) More... about 9 years ago
Send combined size and payload bytes to socket to avoid potentially split packets with TCP_NODELAY (#797) More... about 9 years ago
Release 1.3.0 More... about 9 years ago