P

Python client for Apache Kafka

Settings | Report Duplicate

0

I Use This!

High Activity

Commits : Listings

Analyzed about 14 hours ago. based on code collected about 14 hours ago.

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Jul 30, 2024 — Jul 30, 2025 Showing page 16 of 83 Search / Filter on:
Delay converting to seconds	Jeff Widman	More...				about 6 years ago
Catch TimeoutError in BrokerConnection send/recv (#1820)	Dana Powers	More...				about 6 years ago
Remove unused/weird comment line (#1813)	Jeff Widman	More...				about 6 years ago
Reduce client poll timeout when no ifrs	Dana Powers	More...				about 6 years ago
Update docs for api_version_auto_timeout_ms (#1812)	Jeff Widman	More...				about 6 years ago
Fix typo in _fetch_all_topic_metadata function (#1809)	Brian Sang	More...				about 6 years ago
Make partitions_for_topic a read-through cache (#1781)	Brian Sang	More...				about 6 years ago
Remove unused imports (#1808)	Jeff Widman	More...				about 6 years ago
Use futures to parallelize calls to _send_request_to_node() (#1807)	Lou-Cipher	More...				about 6 years ago
Update link to kafka docs	Jeff Widman	More...				about 6 years ago
A little python cleanup (#1805)	Jeff Widman	More...				about 6 years ago
Bump version for development of next release	Dana Powers	More...				over 6 years ago
Release 1.4.6	Dana Powers	More...				over 6 years ago
Do not call state_change_callback with lock (#1775)	Dana Powers	More...				over 6 years ago
Additional BrokerConnection locks to synchronize protocol/IFR state (#1768)	Dana Powers	More...				over 6 years ago
Return connection state explicitly after close in connect() (#1778)	Dana Powers	More...				over 6 years ago
Reset reconnect backoff on SSL connection (#1777)	Dana Powers	More...				over 6 years ago
Fix possible AttribueError during conn._close_socket (#1776)	Dana Powers	More...				over 6 years ago
Dont treat popped conn.close() as failure in state change callback (#1773)	Dana Powers	More...				over 6 years ago
Avoid race condition on client._conns in send() (#1772)	Dana Powers	More...				over 6 years ago
lock client.check_version (#1771)	Dana Powers	More...				over 6 years ago
Dont wakeup during maybe_refresh_metadata -- it is only called by poll() (#1769)	Dana Powers	More...				over 6 years ago
Fixups to benchmark scripts for py3 / new KafkaFixture interface	Dana Powers	More...				over 6 years ago
Revert 703f0659 / fix 0.8.2 protocol quick detection (#1763)	Dana Powers	More...				over 6 years ago
Send pending requests before waiting for responses (#1762)	Dana Powers	More...				over 6 years ago
Dont do client wakeup when sending from sender thread (#1761)	Dana Powers	More...				over 6 years ago
Update sasl configuration docstrings	Dana Powers	More...				over 6 years ago
Support SASL OAuthBearer Authentication (#1750)	Phong Pham	More...				over 6 years ago
Fix flaky conn tests that use time.time (#1758)	Dana Powers	More...				over 6 years ago
Rename ssl.keystore.location and ssl.truststore.location config files	Dana Powers	More...				over 6 years ago

←
1
2
…
12
13
14
15
16
17
18
19
20
…
82
83
→