P

Python client for Apache Kafka

Settings | Report Duplicate

0

I Use This!

High Activity

Commits : Listings

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

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Jul 01, 2024 — Jul 01, 2025 Showing page 1 of 83 Search / Filter on:
KIP-207: Add ListOffsetsRequest v5 / handle OffsetNotAvailableError (#2657)	Dana Powers	More...				2 days ago
KIP-430: Return Authorized Operations in Describe Responses (#2656)	Dana Powers	More...				4 days ago
python2 fixups (#2655)	Dana Powers	More...				5 days ago
Remove old/unused kafka.protocol.pickle (#2653)	Dana Powers	More...				7 days ago
Switch protocol code to getattr/setattr from __dict__ (#2654)	Dana Powers	More...				7 days ago
cli fixups: producer stdin/eof support; consumer unused e var	Dana Powers	More...				8 days ago
cli fixups: producer py2 compat; consumer no stacktrace on KafkaError	Dana Powers	More...				8 days ago
KIP-345 Consumer group static membership (#2625)	Dana Powers	More...				8 days ago
Fix coordinator lock contention during close() (#2652)	Dana Powers	More...				8 days ago
Drop unused imports (#2651)	Dana Powers	More...				8 days ago
python -m cli interfaces for kafka.admin, kafka.consumer, kafka.producer (#2650)	Dana Powers	More...				8 days ago
Add send_request() and send_requests() to KafkaAdminClient (#2649)	Dana Powers	More...				8 days ago
Patch Release 2.2.13	Dana Powers	More...				11 days ago
Fixup import style in example.py	Dana Powers	More...				12 days ago
Use client.await_ready() to simplify blocking wait and add timeout to admin client (#2648)	Dana Powers	More...				12 days ago
update README kafka version badge to include 4.0	Dana Powers	More...				13 days ago
Patch Release 2.2.12	Dana Powers	More...				13 days ago
Fix construction of final GSSAPI authentication message (#2647)	Dana Powers	More...				13 days ago
Avoid RuntimeError on mutated _completed_fetches deque in consumer fetcher (#2646)	Dana Powers	More...				13 days ago
Throw exception on invalid bucket type (#2642)	Emmanuel Ferdman	More...				21 days ago
Patch Release 2.2.11	Dana Powers	More...				26 days ago
Do not ignore metadata response for single topic with error (#2640)	Dana Powers	More...				26 days ago
Fix decoding bug in AWS_MSK_IAM mechanism (#2639)	Dana Powers	More...				27 days ago
Add synchronized decorator; add lock to subscription state (#2636)	Dana Powers	More...				about 1 month ago
Update build links in documentation (#2634)	Raphael Boidol	More...				about 1 month ago
Patch Release 2.2.10	Dana Powers	More...				about 1 month ago
Pass host as kwarg to get_sasl_mechanism	Dana Powers	More...				about 1 month ago
Set the current host in the SASL configs (#2633)	SeppMe	More...				about 1 month ago
Fix sasl gssapi plugin: do not rely on client_ctx.complete in auth_bytes() (#2631)	Dana Powers	More...				about 1 month ago
Patch Release 2.2.9	Dana Powers	More...				about 1 month ago

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