P

Python client for Apache Kafka

Settings | Report Duplicate

0

I Use This!

High Activity

Commits : Listings

Analyzed 1 day ago. based on code collected 1 day ago.

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Jul 18, 2024 — Jul 18, 2025 Showing page 15 of 83 Search / Filter on:
Issue #1780 - Consumer hang indefinitely in fetcher._retrieve_offsets() due to topic deletion while rebalancing (#1782)	Commander Dishwasher	More...				almost 6 years ago
Change coordinator lock acquisition order (#1821)	Dana Powers	More...				almost 6 years ago
Send socket data via non-blocking IO with send buffer (#1912)	Dana Powers	More...				almost 6 years ago
Do not use wakeup when sending fetch requests from consumer (#1911)	Dana Powers	More...				almost 6 years ago
Rely on socket selector to detect completed connection attempts (#1909)	Dana Powers	More...				almost 6 years ago
Wrap consumer.poll() for KafkaConsumer iteration (#1902)	Dana Powers	More...				almost 6 years ago
Skip admin integration tests -- travis fixture issues	Dana Powers	More...				almost 6 years ago
Update kafka.properties for ACL tests (0.11+ only)	Dana Powers	More...				almost 6 years ago
Fix Admin Client api version checking; only test ACL integration on 0.11+	Dana Powers	More...				almost 6 years ago
Fixup test_admin_integration test fixtures	Dana Powers	More...				almost 6 years ago
Add ACL api to KafkaAdminClient (#1833)	Ulrik Johansson	More...				almost 6 years ago
kafka-python: Fixed crc32c avilability on non-intel architectures. (#1904)	ossdev07	More...				almost 6 years ago
Improve connection lock handling; always use context manager (#1895)	Dana Powers	More...				almost 6 years ago
Convert remaining `KafkaConsumer` tests to `pytest` (#1886)	Jeff Widman	More...				almost 6 years ago
Bump integration tests to 0.10.2.2 and 0.11.0.3 (#1890)	Jeff Widman	More...				almost 6 years ago
Cleanup handling of KAFKA_VERSION env var in tests (#1887)	Jeff Widman	More...				almost 6 years ago
Minor test cleanup (#1885)	Jeff Widman	More...				almost 6 years ago
Reduce internal client poll timeout for consumer iterator interface (#1824)	Dana Powers	More...				almost 6 years ago
Update conn.py	Cameron Boulton	More...				almost 6 years ago
tests: Use socket.SOCK_STREAM in assertions	Ivan A. Melnikov	More...				almost 6 years ago
Break FindCoordinator into request/response methods	Jeff Widman	More...				almost 6 years ago
Fix minor typo (#1865)	Carson Ip	More...				about 6 years ago
Update link to upstream Kafka docs	Jeff Widman	More...				about 6 years ago
Add the `sasl_kerberos_domain_name` arg to `KafkaAdminClient`	Jeff Widman	More...				about 6 years ago
Update KafkaAdminClient Docs	Rob Cardy	More...				about 6 years ago
Break consumer operations into request / response methods (#1845)	Jeff Widman	More...				about 6 years ago
Use dedicated connection for group coordinator (#1822)	Dana Powers	More...				about 6 years ago
Allow the coordinator to auto-commit for all api_version.	Jay Chan	More...				about 6 years ago
Sanity test for consumer.topics() and consumer.partitions_for_topic()	Brian Sang	More...				about 6 years ago
Delay converting to seconds	Jeff Widman	More...				about 6 years ago

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