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 19, 2024 — Jul 19, 2025 Showing page 6 of 83 Search / Filter on:
Lazy _unpack_records in PartitionRecords	Dana Powers	More...				4 months ago
Debug log fetch records return; separate offsets update log	Dana Powers	More...				4 months ago
revert last_offset_from_record_batch	Dana Powers	More...				4 months ago
Add FetchMetrics class; move topic_fetch_metrics inside aggregator	Dana Powers	More...				4 months ago
DefaultRecordsBatchBuilder: support empty batch	Dana Powers	More...				4 months ago
MemoryRecordsBuilder: support arbitrary offset, skipping offsets	Dana Powers	More...				4 months ago
Add record.validate_crc() for v0/v1 crc checks	Dana Powers	More...				4 months ago
remove fetcher message_generator / iterator interface	Dana Powers	More...				4 months ago
Add size_in_bytes to ABCRecordBatch and implement for Legacy and Default	Dana Powers	More...				4 months ago
Add magic property to ABCRecord and implement for LegacyRecord	Dana Powers	More...				4 months ago
Fix Fetcher retriable error handling (#2554)	Dana Powers	More...				4 months ago
Use six.add_metaclass for py2/py3 compatible abc (#2551)	Dana Powers	More...				4 months ago
Bump version for development	Dana Powers	More...				4 months ago
Fix StickyPartitionAssignor encode	Dana Powers	More...				4 months ago
Patch Release 2.1.1	Dana Powers	More...				4 months ago
Fix packaging of 2.1.0 in Fedora: testing requires "pytest-timeout". (#2550)	Romain Geissler @ Amadeus	More...				4 months ago
Improve connection error handling when try_api_versions_check fails all attempts (#2548)	Dana Powers	More...				4 months ago
Add lock synchronization to Future success/failure (#2549)	Dana Powers	More...				4 months ago
Bump version for development / fix release date	Dana Powers	More...				4 months ago
Release 2.1.0	Dana Powers	More...				4 months ago
Call default_offset_commit_callback after _maybe_auto_commit_offsets_async (#2546)	Dana Powers	More...				4 months ago
Add optional timeout_ms kwarg to remaining consumer/coordinator methods (#2544)	Dana Powers	More...				4 months ago
Remove legacy/v1 consumer message iterator (#2543)	Dana Powers	More...				4 months ago
Raise immediate error on producer.send after close (#2542)	Dana Powers	More...				4 months ago
Bump default python to 3.13 in CI tests (#2541)	Dana Powers	More...				4 months ago
Log warning when attempting to list offsets for unknown topic/partition (#2540)	Dana Powers	More...				4 months ago
Delay group coordinator until after bootstrap (#2539)	Dana Powers	More...				4 months ago
Fix OverflowError when connection_max_idle_ms is 0 or inf (#2538)	Dana Powers	More...				4 months ago
KafkaProducer: Flush pending records before close() (#2537)	Dana Powers	More...				4 months ago
Only refresh metadata if connection fails all dns records (#2532)	Dana Powers	More...				4 months ago

←
1
2
3
4
5
6
7
8
9
10
…
82
83
→