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 02, 2024 — Jul 02, 2025 Showing page 8 of 83 Search / Filter on:
Support AWS_MSK_IAM authentication (#2519)	Dana Powers	More...				4 months ago
Make the "mock" dependency optional (only used in Python < 3.3). (#2518)	Romain Geissler @ Amadeus	More...				4 months ago
Remove tox.ini; update testing docs	Dana Powers	More...				4 months ago
Document api_version_auto_timeout_ms default; override in group tests	Dana Powers	More...				4 months ago
Cleanup sasl mechanism configuration checks; fix gssapi bugs; add sasl_kerberos_name config (#2520)	Dana Powers	More...				4 months ago
Refactor Sasl authentication with SaslMechanism abstract base class; support SaslAuthenticate (#2515)	Dana Powers	More...				4 months ago
Use thread-specific client_id in test_group	Dana Powers	More...				4 months ago
Call ApiVersionsRequest during connection, prior to Sasl Handshake (#2493)	Dana Powers	More...				4 months ago
1.1 broker_api_versions	Dana Powers	More...				4 months ago
Add baseline leader_epoch support for ListOffsets v4 / FetchRequest v10 (#2511)	Dana Powers	More...				4 months ago
Implement client-side connection throttling / KIP-219 (#2510)	Dana Powers	More...				4 months ago
Fix subprocess log warning; specify timeout_ms kwarg in consumer.poll tests	Dana Powers	More...				4 months ago
Fixup fetch request forgotten_topics_data encoding	Dana Powers	More...				4 months ago
2.0.6 changelog	Dana Powers	More...				4 months ago
Improve too-large timeout handling in client poll	Dana Powers	More...				4 months ago
Implement Incremental Fetch Sessions / KIP-227 (#2508)	Dana Powers	More...				4 months ago
Client connection / maybe_refresh_metadata changes (#2507)	Dana Powers	More...				4 months ago
Add throttle warnings and top-level error handling for new offset commit/fetch handling	Dana Powers	More...				4 months ago
Support OffsetFetch v5 / OffsetCommit v6 (2.1 baseline) (#2505)	Dana Powers	More...				4 months ago
Improve error handling in client._maybe_connect (#2504)	Dana Powers	More...				4 months ago
Support 2.1 baseline consumer group apis (#2503)	Dana Powers	More...				4 months ago
Support FindCoordinatorRequest v2 in consumer and admin client (#2502)	Dana Powers	More...				4 months ago
Support ListOffsets v3 in consumer (#2501)	Dana Powers	More...				4 months ago
Support Fetch Request/Response v6 in consumer (#2500)	Dana Powers	More...				4 months ago
Support custom per-request timeouts (#2498)	Dana Powers	More...				4 months ago
try / except in consumer coordinator __del__	Dana Powers	More...				4 months ago
Decode and skip transactional control records in consumer (#2499)	Dana Powers	More...				4 months ago
Add support for Metadata Request/Response v7 (#2497)	Dana Powers	More...				4 months ago
Default client.check_version timeout to api_version_auto_timeout_ms (#2496)	Dana Powers	More...				4 months ago
Add KafkaClient.api_version(operation) for best available from api_versions (#2495)	Dana Powers	More...				4 months ago

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