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 9 of 83 Search / Filter on:
Add support for Metadata Request/Response v7 (#2497)	Dana Powers	More...				5 months ago
Default client.check_version timeout to api_version_auto_timeout_ms (#2496)	Dana Powers	More...				5 months ago
Add KafkaClient.api_version(operation) for best available from api_versions (#2495)	Dana Powers	More...				5 months ago
Fake api_versions for old brokers, rename to ApiVersionsRequest, and handle error decoding (#2494)	Dana Powers	More...				5 months ago
Only set KAFKA_JVM_PERFORMANCE_OPTS in makefile if unset; add note re: 2.0-2.3 broker testing	Dana Powers	More...				5 months ago
Add kafka command to test.brokers; raise FileNotFoundError if version not installed	Dana Powers	More...				5 months ago
test_conn fixup for py2	Dana Powers	More...				5 months ago
Bump version for development	Dana Powers	More...				5 months ago
Release 2.0.5	Dana Powers	More...				5 months ago
rename make target api_versions.txt -> api_versions	Dana Powers	More...				5 months ago
fixup compatibility badges	Dana Powers	More...				5 months ago
Remove unused client bootstrap backoff code	Dana Powers	More...				5 months ago
admin client: check_version only if needed, node_id kwarg for controller	Dana Powers	More...				5 months ago
make servers//api_versions.txt and make servers//messages	Dana Powers	More...				5 months ago
include client_id in BrokerConnection __str__ output	Dana Powers	More...				5 months ago
Also sleep when waiting for consumers in test_describe_consumer_group_exists	Dana Powers	More...				5 months ago
Refactor sasl_integration test_client - wait for node ready; use send future	Dana Powers	More...				5 months ago
Add timeout to test_kafka_consumer	Dana Powers	More...				5 months ago
Add error str to assert_message_count checks	Dana Powers	More...				5 months ago
Retry on error in fixture _create_topic_via_metadata	Dana Powers	More...				5 months ago
Fixup variable interpolation in test fixture error	Dana Powers	More...				5 months ago
Check for -1 controller_id in admin client	Dana Powers	More...				5 months ago
only acquire coordinator lock in heartbeat thread close if not self thread	Dana Powers	More...				5 months ago
200ms timeout for client.poll in ensure_active_group and admin client	Dana Powers	More...				5 months ago
Update compatibility docs	Dana Powers	More...				5 months ago
Bump version for development	Dana Powers	More...				5 months ago
Release 2.0.4 (#2489)	Dana Powers	More...				5 months ago
Update kafka/admin/client docstrings to google format	Dana Powers	More...				5 months ago
Added missing docstrings in admin/client.py (#2487)	Luka Lafaye de Micheaux	More...				5 months ago
Fixup pytest run w/o KAFKA_VERSION	Dana Powers	More...				5 months ago

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