P

Python client for Apache Kafka

Settings | Report Duplicate

0

I Use This!

Moderate Activity

Commits : Listings

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

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Aug 05, 2024 — Aug 05, 2025 Showing page 21 of 83 Search / Filter on:
Bump version for development	Dana Powers	More...				over 7 years ago
Patch Release 1.4.2	Dana Powers	More...				over 7 years ago
KAFKA-5512; Awake the heartbeat thread when timetoNextHeartbeat is equal to 0 (#1439)	Dana Powers	More...				over 7 years ago
Add kafka 1.0.1 release to test fixtures (#1437)	Dana Powers	More...				over 7 years ago
Remove old CommitFailed error message from coordinator (#1436)	Dana Powers	More...				over 7 years ago
Update changelog with unreleased 1.4.2 notes	Dana Powers	More...				over 7 years ago
Validate that serializers generate bytes-like (or None) data (#1420)	Dana Powers	More...				over 7 years ago
Do not validate api_version against known versions (#1434)	Dana Powers	More...				over 7 years ago
Connect with sockaddrs to support non-zero ipv6 scope ids (#1433)	Dana Powers	More...				over 7 years ago
Re-enable logging during broker version check (#1430)	Dana Powers	More...				over 7 years ago
Connection logging cleanups (#1432)	Dana Powers	More...				over 7 years ago
Add BrokerConnection.connect_blocking() (#1411)	Dana Powers	More...				over 7 years ago
Short-circuit BrokerConnection.close() if already disconnected (#1424)	Dana Powers	More...				over 7 years ago
Only increase reconnect backoff if all addrinfos have been tried (#1423)	Dana Powers	More...				over 7 years ago
Support alternative lz4framed (#1395)	everpcpc	More...				over 7 years ago
Close leaked selector in version check (#1425)	Dana Powers	More...				over 7 years ago
Make BrokerConnection .host / .port / .afi immutable, use _sock_* attributes for current lookups (#1422)	Dana Powers	More...				over 7 years ago
Avoid tight poll loop in consumer when brokers are down (#1415)	Dana Powers	More...				over 7 years ago
Fix BrokerConnection.connection_delay() to return milliseconds (#1414)	Dana Powers	More...				over 7 years ago
Close KafkaConsumer instances during tests (#1410)	Dana Powers	More...				over 7 years ago
Use local copies in Fetcher._fetchable_partitions to avoid mutation errors (#1400)	Dana Powers	More...				over 7 years ago
Fix error var name in _unpack (#1403)	j2gg0s	More...				over 7 years ago
Validate max_records in KafkaConsumer.poll (#1398)	Dana Powers	More...				over 7 years ago
Fix KafkaConsumer compacted offset handling (#1397)	Dana Powers	More...				over 7 years ago
Fix byte size estimation with kafka producer (#1393)	Blake Embrey	More...				over 7 years ago
Use hardware accelerated CRC32C function if available (#1389)	Taras Voinarovskyi	More...				over 7 years ago
Correctly respect timeouts in consumer poll interface (#1384)	Braedon Vickers	More...				over 7 years ago
Fix response schema	Alex Eftimie	More...				over 7 years ago
Add Admin CreatePartitions API call	Alex Eftimie	More...				over 7 years ago
Removed pytest-catchlog dependency	Andre Araujo	More...				over 7 years ago

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