P

Python client for Apache Kafka

Settings | Report Duplicate

0

I Use This!

High Activity

Commits : Listings

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

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Jul 25, 2024 — Jul 25, 2025 Showing page 4 of 83 Search / Filter on:
Fix client.wakeup() race from producer/sender close	Dana Powers	More...				3 months ago
Avoid self refcount in log messages; test thread close on all pythons	Dana Powers	More...				3 months ago
KAFKA-4547: Avoid resetting paused partitions to committed offsets	Dana Powers	More...				3 months ago
Prefix producer logs w/ client id and transactional id (#2591)	Dana Powers	More...				3 months ago
fixup reset_producer_id is_transactional() check	Dana Powers	More...				3 months ago
KIP-98: Add offsets support to transactional KafkaProducer (#2590)	Dana Powers	More...				3 months ago
Fixup retry/sleep after successful init producer id in idempotent producer	Dana Powers	More...				3 months ago
Remove old/unused errors; reorder; KafkaTimeout -> retriable	Dana Powers	More...				3 months ago
Resolve datetime deprecation warnings (#2589)	Emmanuel Ferdman	More...				3 months ago
py2 test fixups	Dana Powers	More...				3 months ago
KIP-98: Transactional Producer (#2587)	Dana Powers	More...				3 months ago
Move integration tests and fixtures to test/integration/; simplify unit fixtures (#2588)	Dana Powers	More...				3 months ago
Expand Sender test coverage (#2586)	Dana Powers	More...				4 months ago
Dont raise KeyError on incomplete.remove(batch)	Dana Powers	More...				4 months ago
Rename CorruptRecordException -> CorruptRecordError	Dana Powers	More...				4 months ago
Rename Coordinator errors to generic not group (#2585)	Dana Powers	More...				4 months ago
KIP-98: Add Consumer support for READ_COMMITTED (#2582)	Dana Powers	More...				4 months ago
fixup Sender._fail_batch	Dana Powers	More...				4 months ago
Use SaslAuthenticationFailedError in kafka.conn connection failure Drop unused AuthenticationFailedError	Dana Powers	More...				4 months ago
KIP-98: Add idempotent producer support (#2569)	Dana Powers	More...				4 months ago
Cluster.add_group_coordinator -> add_coordinator + support txn type	Dana Powers	More...				4 months ago
Add protocol defs for AddPartitionsToTxn, EndTxn, and AddOffsetsToTxn	Dana Powers	More...				4 months ago
Bump version for development	Dana Powers	More...				4 months ago
Patch Release 2.1.5	Dana Powers	More...				4 months ago
Move benchmark scripts to kafka.benchmarks module (#2584)	Dana Powers	More...				4 months ago
Use __slots__ for metrics (#2583)	Dana Powers	More...				4 months ago
Pass metrics_enabled=False to disable metrics (#2581)	Dana Powers	More...				4 months ago
Drop unused kafka.producer.buffer / SimpleBufferPool (#2580)	Dana Powers	More...				4 months ago
Raise UnsupportedVersionError from coordinator (#2579)	Dana Powers	More...				4 months ago
Fix python2.7 errors (#2578)	Dana Powers	More...				4 months ago

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