P

Python client for Apache Kafka

Settings | Report Duplicate

0

I Use This!

High Activity

Commits : Listings

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

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Jul 18, 2024 — Jul 18, 2025 Showing page 3 of 83 Search / Filter on:
Ignore leading SECURITY_PROTOCOL:// in bootstrap_servers (#2608)	Dana Powers	More...				3 months ago
Only create fetch requests for ready nodes (#2607)	Dana Powers	More...				3 months ago
Bump version for development	Dana Powers	More...				3 months ago
Patch Release 2.2.2	Dana Powers	More...				3 months ago
Fix lint errors	Dana Powers	More...				3 months ago
Bump version for development	Dana Powers	More...				3 months ago
Patch Release 2.2.1	Dana Powers	More...				3 months ago
Always try ApiVersionsRequest v0, even on broker disconnect (#2603)	Dana Powers	More...				3 months ago
Fix SubscriptionState AttributeError in KafkaConsumer (#2599)	cheterchao	More...				3 months ago
Add transactional examples to docs	Dana Powers	More...				3 months ago
Bump version for development	Dana Powers	More...				3 months ago
Release 2.2.0	Dana Powers	More...				3 months ago
KIP-394: handle MEMBER_ID_REQUIRED error w/ second join group request (#2598)	Dana Powers	More...				3 months ago
RecordAccumulator: Use helper method to get/set _tp_locks; get dq with lock in reenqueue()	Dana Powers	More...				3 months ago
Expand KafkaProducer docstring w/ idempotent and transactional notes	Dana Powers	More...				3 months ago
Default retries -> infinite	Dana Powers	More...				3 months ago
KIP-91: KafkaProducer delivery_timeout_ms	Dana Powers	More...				3 months ago
MemoryRecords iterator; MemoryRecordsBuilder records() helper	Dana Powers	More...				3 months ago
DefaultRecordsBuilder.size_in_bytes classmethod	Dana Powers	More...				3 months ago
from __future__ import division for produce batch time calcs	Dana Powers	More...				3 months ago
KAFKA-5429 - Ignore produce response if batch was previously aborted	Dana Powers	More...				3 months ago
Do not include log_start_offset in producer RecordMetadata	Dana Powers	More...				3 months ago
Fix ElectionNotNeededError handling in admin client	Dana Powers	More...				3 months ago
KAFKA-6397: Consumer should not block setting positions of unavailable partitions (#2593)	Dana Powers	More...				3 months ago
fixup exception message	Dana Powers	More...				3 months ago
Drop unused KafkaClient import from test_fetcher	Dana Powers	More...				3 months ago
KAFKA-5078 - defer fetch record exception if iterator has already moved across a valid record	Dana Powers	More...				3 months ago
KAFKA-5075 - Defer consumer fetcher exception if fetch position has already increased	Dana Powers	More...				3 months ago
KAFKA-4937: Batch offset fetches in the Consumer	Dana Powers	More...				3 months ago
Fix client.wakeup() race from producer/sender close	Dana Powers	More...				3 months ago

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