P

Python client for Apache Kafka

Settings | Report Duplicate

0

I Use This!

High Activity

Commits : Listings

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

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Jul 30, 2024 — Jul 30, 2025 Showing page 7 of 83 Search / Filter on:
Limit producer close timeout to 1sec in __del__; use context managers to close in test_producer	Dana Powers	More...				5 months ago
Signal close to metrics expire_loop	Dana Powers	More...				5 months ago
Admin - Implement perform leader election (#2536)	Dana Powers	More...				5 months ago
AdminClient: support delete_records (#2535)	Dana Powers	More...				5 months ago
Include request_timeout_ms in request debug log	Dana Powers	More...				5 months ago
Debug log if check_version connection attempt fails	Dana Powers	More...				5 months ago
Use NullLogger in producer atexit cleanup	Dana Powers	More...				5 months ago
Add heartbeat thread id to debug logs on start	Dana Powers	More...				5 months ago
Update pytest log_format: use logger instead of filename; add thread id	Dana Powers	More...				5 months ago
Improve test_consumer_group::test_group logging before group stabilized (#2534)	Dana Powers	More...				5 months ago
Limit test duration to 5mins w/ pytest-timeout	Dana Powers	More...				5 months ago
Fix external kafka/zk fixtures for testing (#2533)	Dana Powers	More...				5 months ago
Debug log when skipping api_versions request with pre-configured api_version	Dana Powers	More...				5 months ago
Disable zookeeper admin server to avoid port conflicts	Dana Powers	More...				5 months ago
Set default pytest log level to debug	Dana Powers	More...				5 months ago
KAFKA-4160: Ensure rebalance listener not called with coordinator lock (#1438)	Dana Powers	More...				5 months ago
Move inner_timeout_ms def to kafka.util timeout_ms_fn	Dana Powers	More...				5 months ago
Add inner_timeout_ms handler to fetcher; add fallback (#2529)	Dana Powers	More...				5 months ago
Only mark coordinator dead if connection_delay > 0 (#2530)	Dana Powers	More...				5 months ago
reset rejoin_needed after _on_join_complete	Dana Powers	More...				5 months ago
Check for coordinator.poll failure in KafkaConsumer	Dana Powers	More...				5 months ago
test_group: shorter timeout, more logging, more sleep	Dana Powers	More...				5 months ago
Support client.poll with future and timeout_ms	Dana Powers	More...				5 months ago
Timeout coordinator poll / ensure_coordinator_ready / ensure_active_group (#2526)	Dana Powers	More...				5 months ago
Cache servers/dist in github actions workflow (#2527)	Dana Powers	More...				5 months ago
Improve ClusterMetadata docs re: node_id/broker_id str/int types	Dana Powers	More...				5 months ago
Move kafka.oauth.AbstractTokenProvider -> kafka.sasl.oauth.AbstractTokenProvider (#2525)	Dana Powers	More...				5 months ago
Remove unused partial KIP-467 implementation (ProduceResponse batch error details) (#2524)	Dana Powers	More...				5 months ago
mask unused afi var	Dana Powers	More...				5 months ago
fixup TopicAuthorizationFailedError construction	Dana Powers	More...				5 months ago

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