P

Python client for Apache Kafka

Settings | Report Duplicate

0

I Use This!

Moderate Activity

Commits : Listings

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

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Aug 15, 2024 — Aug 15, 2025 Showing page 1 of 11 Search / Filter on:
Fetcher: Add missing argument in debug log (#2665)	Alexandre Feblot	More...				27 days ago
KIP-654: Abort transaction with pending data with TransactionAbortedError (#2662)	Dana Powers	More...				about 1 month ago
KafkaProducer: Handle UnknownProducerIdError (#2663)	Dana Powers	More...				about 1 month ago
KIP-467: Augment ProduceResponse error messaging for specific culprit records (#2661)	Dana Powers	More...				about 1 month ago
Update changelog for 2.2 patch releases + bump version for 2.3.x releases	Dana Powers	More...				about 2 months ago
Fix KafkaProducer broken method names (#2660)	llk89	More...				about 2 months ago
Fix spelling mistake in KafkaConsumer docs (#2659)	Xeus-CC	More...				about 2 months ago
KIP-207: Add ListOffsetsRequest v5 / handle OffsetNotAvailableError (#2657)	Dana Powers	More...				about 2 months ago
KIP-430: Return Authorized Operations in Describe Responses (#2656)	Dana Powers	More...				about 2 months ago
python2 fixups (#2655)	Dana Powers	More...				about 2 months ago
Remove old/unused kafka.protocol.pickle (#2653)	Dana Powers	More...				about 2 months ago
Switch protocol code to getattr/setattr from __dict__ (#2654)	Dana Powers	More...				about 2 months ago
cli fixups: producer stdin/eof support; consumer unused e var	Dana Powers	More...				about 2 months ago
cli fixups: producer py2 compat; consumer no stacktrace on KafkaError	Dana Powers	More...				about 2 months ago
KIP-345 Consumer group static membership (#2625)	Dana Powers	More...				about 2 months ago
Fix coordinator lock contention during close() (#2652)	Dana Powers	More...				about 2 months ago
Drop unused imports (#2651)	Dana Powers	More...				about 2 months ago
python -m cli interfaces for kafka.admin, kafka.consumer, kafka.producer (#2650)	Dana Powers	More...				about 2 months ago
Add send_request() and send_requests() to KafkaAdminClient (#2649)	Dana Powers	More...				about 2 months ago
Patch Release 2.2.13	Dana Powers	More...				about 2 months ago
Fixup import style in example.py	Dana Powers	More...				about 2 months ago
Use client.await_ready() to simplify blocking wait and add timeout to admin client (#2648)	Dana Powers	More...				about 2 months ago
update README kafka version badge to include 4.0	Dana Powers	More...				about 2 months ago
Patch Release 2.2.12	Dana Powers	More...				about 2 months ago
Fix construction of final GSSAPI authentication message (#2647)	Dana Powers	More...				about 2 months ago
Avoid RuntimeError on mutated _completed_fetches deque in consumer fetcher (#2646)	Dana Powers	More...				about 2 months ago
Throw exception on invalid bucket type (#2642)	Emmanuel Ferdman	More...				2 months ago
Patch Release 2.2.11	Dana Powers	More...				2 months ago
Do not ignore metadata response for single topic with error (#2640)	Dana Powers	More...				2 months ago
Fix decoding bug in AWS_MSK_IAM mechanism (#2639)	Dana Powers	More...				2 months ago

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