P

Python client for Apache Kafka

Settings | Report Duplicate

0

I Use This!

Moderate 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
Aug 04, 2024 — Aug 04, 2025 Showing page 22 of 83 Search / Filter on:
Fixes racing condition when message is sent to broker before topic logs are created	Andre Araujo	More...				over 7 years ago
Bump version for development	Dana Powers	More...				over 7 years ago
Patch Release 1.4.1 (#1376)	Dana Powers	More...				over 7 years ago
Fix consumer poll stuck error when no available partition (#1375)	Yu Kou	More...				over 7 years ago
Increase some integration test timeouts (#1374)	Dana Powers	More...				over 7 years ago
Use raw in case string overriden (#1373)	Jeff Widman	More...				over 7 years ago
Fix pending completion IndexError bug caused by multiple threads (#1372)	Dana Powers	More...				over 7 years ago
Bump version for development of next release	Dana Powers	More...				over 7 years ago
Release 1.4.0	Dana Powers	More...				over 7 years ago
pylint 1.8.2 (#1369)	Dana Powers	More...				over 7 years ago
use absolute imports everywhere (#1362)	Kevin Tindall	More...				over 7 years ago
Add Request/Response structs for kafka broker 1.0.0	Dana Powers	More...				over 7 years ago
Avoid consuming duplicate compressed messages from mid-batch (#1367)	Dana Powers	More...				over 7 years ago
KAFKA-3949: Avoid race condition when subscription changes during rebalance (#1364)	Dana Powers	More...				over 7 years ago
Add kafka 1.0.0 to travis integration tests	Dana Powers	More...				over 7 years ago
Bump `lz4` in `requirements-dev.txt` (#1359)	Jeff Widman	More...				over 7 years ago
Use latest pytest 3.4.0, but drop pytest-sugar due to incompatibility (#1361)	Dana Powers	More...				over 7 years ago
Stop pinning lz4	Jeff Widman	More...				over 7 years ago
Use 0.11.0.2 kafka broker for integration testing (#1357)	Dana Powers	More...				over 7 years ago
Fix for Python 3 byte string handling in SASL auth (#1353)	Christophe Lecointe	More...				over 7 years ago
Remove assertion with side effect (#1348)	Buğra Gedik	More...				over 7 years ago
fix reconnect_backoff_max_ms default config bug in KafkaProducer (#1352)	C.YAO	More...				over 7 years ago
Name heartbeat thread with group_id; use backoff when polling (#1345)	Dana Powers	More...				over 7 years ago
Minor test cleanups (#1343)	Dana Powers	More...				over 7 years ago
Avoid KeyError when filtering fetchable partitions (#1344)	Dana Powers	More...				over 7 years ago
Honor reconnect_backoff in conn.connect() (#1342)	Dana Powers	More...				over 7 years ago
Fix coordinator join_future race condition (#1338)	Dana Powers	More...				over 7 years ago
Read all available socket bytes (#1332)	Dana Powers	More...				over 7 years ago
Improve KafkaConsumer cleanup (#1339)	Dana Powers	More...				over 7 years ago
Fix typo in _try_authenticate_plain (#1333)	everpcpc	More...				over 7 years ago

←
1
2
…
18
19
20
21
22
23
24
25
26
…
82
83
→