P

Python client for Apache Kafka

Settings | Report Duplicate

0

I Use This!

High Activity

Commits : Listings

Analyzed about 6 hours ago. based on code collected about 7 hours ago.

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Jul 26, 2024 — Jul 26, 2025 Showing page 76 of 83 Search / Filter on:
Merge branch 'repr' of https://github.com/mahendra/kafka-python into mahendra-repr	mrtheb	More...				over 11 years ago
Merge pull request #100 from cosbynator/no_infinite_loops_real	Omar	More...				over 11 years ago
Make integration test warming more intuitive	Thomas Dimson	More...				over 11 years ago
Add a few 9s test_multi_process_consumer, make clear what setUp is doing	Thomas Dimson	More...				over 11 years ago
Throw KafkaUnavailableError when no brokers available	Thomas Dimson	More...				over 11 years ago
Merge pull request #99 from vadimg/master	Omar	More...				over 11 years ago
Exception hierarchy, invalidate more md on errors	Thomas Dimson	More...				over 11 years ago
remove zero length field name in format string, to work in Python 2.6	Vadim Graboys	More...				over 11 years ago
Merge pull request #88 from rdiomar/rdiomar_changes	Omar	More...				over 11 years ago
Change log.error() back to log.exception()	Omar Ghishan	More...				over 11 years ago
Change BufferUnderflowError to ConnectionError in conn._read_bytes() Both errors are handled the same way when raised and caught, so this makes sense.	Omar Ghishan	More...				over 11 years ago
Merge pull request #66 from jcrobak/fix-import-collision	David Arthur	More...				over 11 years ago
Some cleanup and easier to read test fixture output	Omar Ghishan	More...				over 11 years ago
Skip snappy/gzip tests if they're not available	Omar Ghishan	More...				over 11 years ago
Remove unnecessary method	Omar Ghishan	More...				over 11 years ago
Handle dirty flag in conn.recv()	Omar Ghishan	More...				over 11 years ago
Use the same timeout when reinitializing a connection	Omar Ghishan	More...				over 11 years ago
Deleting client_id from offset commit and fetch response as per Kafka trunk code	Ashish Walia	More...				over 11 years ago
Syncing offset commit and fetch api keys with Kafka trunk code	Ashish Walia	More...				over 11 years ago
Add object type and ID to message prefix in fixtures output for easier debugging	Omar Ghishan	More...				over 11 years ago
Make kafka brokers per-test in failover integration tests	Omar Ghishan	More...				over 11 years ago
Add tests for limited and unlimited consumer max_buffer_size	Omar Ghishan	More...				over 11 years ago
Fix client and consumer params in integration tests	Omar Ghishan	More...				over 11 years ago
Remove unnecessary brackets	Omar Ghishan	More...				over 11 years ago
Handle starting/stopping Kafka brokers that are already started/stopped in integration tests	Omar Ghishan	More...				over 11 years ago
Add a limit to fetch buffer size, and actually retry requests when fetch size is too small	Omar Ghishan	More...				over 11 years ago
Fix client error handling	Omar Ghishan	More...				over 11 years ago
Raise a ConnectionError when a socket.error is raised when receiving data Also, log.exception() is unhelpfully noisy. Use log.error() with some error details in the message instead.	Omar Ghishan	More...				over 11 years ago
Fix seek offset deltas	Omar Ghishan	More...				over 11 years ago
Style fix for imports	Omar Ghishan	More...				over 11 years ago

←
1
2
…
72
73
74
75
76
77
78
79
80
81
82
83
→