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 16, 2024 — Jul 16, 2025 Showing page 5 of 83 Search / Filter on:
Patch Release 2.1.4	Dana Powers	More...				4 months ago
Dont block pending FetchRequests when Metadata update requested (#2576)	Dana Powers	More...				4 months ago
Improve connection state logging (#2574)	Dana Powers	More...				4 months ago
Fix MetadataRequest for no topics (#2573)	Dana Powers	More...				4 months ago
Send final error byte x01 on Sasl OAuth failure (#2572)	Dana Powers	More...				4 months ago
Update Makefile default to 4.0 broker; add make fixture	Dana Powers	More...				4 months ago
Reset SASL state on disconnect (#2571)	Dana Powers	More...				4 months ago
Try import new Sequence before old to avoid DeprecationWarning	Dana Powers	More...				4 months ago
Patch Release 2.1.3	Dana Powers	More...				4 months ago
Also update config api_version to closest compatible (#2567)	Dana Powers	More...				4 months ago
Use SubscriptionType to track topics/pattern/user assignment (#2565)	Dana Powers	More...				4 months ago
KIP-74: Manage assigned partition order in consumer (#2562)	Dana Powers	More...				4 months ago
More timeout_ms args in coordinator + heartbeat close	Dana Powers	More...				4 months ago
timeout on consumer_factory in test_producer	Dana Powers	More...				4 months ago
Add optional timeout_ms kwarg to consumer.close() / fix potential hang in test_group (#2564)	Dana Powers	More...				4 months ago
KIP-70: Auto-commit offsets on consumer.unsubscribe(), defer assignment changes to rejoin (#2560)	Dana Powers	More...				4 months ago
Fix maximum version to send an OffsetFetchRequest (#2563)	Guillaume Arnaud	More...				4 months ago
Move ensure_valid_topic_name to kafka.util; use in client and producer (#2561)	Dana Powers	More...				4 months ago
Test older pythons against 4.0 broker	Dana Powers	More...				4 months ago
Use get_open_port for KRaft controller port	Dana Powers	More...				4 months ago
Update kafka broker compatibility docs	Dana Powers	More...				4 months ago
Support KRaft / 4.0 brokers in tests (#2559)	Dana Powers	More...				4 months ago
KIP-511: Use ApiVersions v4 on initial connect w/ client_software_name + version (#2558)	Dana Powers	More...				4 months ago
Add python 3.13 to compatibility list	Dana Powers	More...				4 months ago
Return empty set from consumer.partitions_for_topic when topic not found (#2556)	Dana Powers	More...				4 months ago
Bump version for development	Dana Powers	More...				4 months ago
Patch Release 2.1.2	Dana Powers	More...				4 months ago
simplify consumer.poll send fetches logic	Dana Powers	More...				4 months ago
Validate crcs in fetcher	Dana Powers	More...				4 months ago
Lazy _unpack_records in PartitionRecords	Dana Powers	More...				4 months ago

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