P

Python client for Apache Kafka

Settings | Report Duplicate

0

I Use This!

High Activity

Commits : Listings

Analyzed 1 day ago. based on code collected 1 day ago.

Commit Message	Contributor	Files Modified	Lines Added	Lines Removed	Code Location	Date
Jul 16, 2024 — Jul 16, 2025 Showing page 77 of 83 Search / Filter on:
Add note about questionable error handling while decoding messages. Will remove once any error handling issues are resolved.	Omar Ghishan	More...				over 11 years ago
Add and fix comments to protocol.py	Omar Ghishan	More...				over 11 years ago
Merge pull request #84 from nieksand/simpler_timeouts	David Arthur	More...				over 11 years ago
Merge pull request #83 from eklitzke/master	David Arthur	More...				over 11 years ago
Remove tox from requires	David Arthur	More...				over 11 years ago
Replaced _send_upstream datetime logic with simpler time().	Niek Sanders	More...				over 11 years ago
reduce memory copies when consuming kafka responses	Evan Klitzke	More...				over 11 years ago
Add comments and maintain 80 character line limit	Omar Ghishan	More...				over 11 years ago
Add iter_timeout option to SimpleConsumer. If not None, it causes the iterator to exit when reached. Also put constant timeout values in pre-defined constants	Omar Ghishan	More...				over 11 years ago
Add buffer_size param description to docstring	Omar Ghishan	More...				over 11 years ago
Remove SimpleConsumer queue size limit since it can cause the iterator to block forever if it's reached.	Omar Ghishan	More...				over 11 years ago
SimpleConsumer flow changes: * Combine partition fetch requests into a single request * Put the messages received in a queue and update offsets * Grab as many messages from the queue as requested * When the queue is empty, request more * timeout param for get_messages() is the actual timeout for getting those messages * Based on https://github.com/mumrah/kafka-python/pull/74 - don't increase min_bytes if the consumer fetch buffer size is too small.	Omar Ghishan	More...				over 11 years ago
Reset consumer fields to original values rather than defaults in FetchContext	Omar Ghishan	More...				over 11 years ago
Allow None timeout in FetchContext even if block is False	Omar Ghishan	More...				over 11 years ago
* Guarantee reading the expected number of bytes from the socket every time * Remove bufsize from client and conn, since they're not actually enforced	Omar Ghishan	More...				over 11 years ago
Read the correct number of bytes from kafka.	Omar Ghishan	More...				over 11 years ago
Allow customizing socket timeouts.	Omar Ghishan	More...				over 11 years ago
Merge pull request #77 from zever/timeout-none	David Arthur	More...				over 11 years ago
Merge pull request #78 from zever/README-typo	David Arthur	More...				over 11 years ago
fix typo in README acks_timeout -> ack_timeout	Zack Dever	More...				over 11 years ago
allow for timeout to be None in SimpleConsumer.get_messages	Zack Dever	More...				over 11 years ago
Update kafka-src to 0.8.0 tag	David Arthur	More...				over 11 years ago
Allow KafkaClient to take in a list of brokers for bootstrapping	Marc Labbe	More...				over 11 years ago
Set host and port in ExternalService test fixture	David Arthur	More...				over 11 years ago
Enable absolute imports for modules using Queue.	Joe Crobak	More...				over 11 years ago
Merge pull request #62 from mahendra/cons-windows	Mahendra M	More...				almost 12 years ago
Add proper string representations for each class	Mahendra M	More...				almost 12 years ago
Ensure that multiprocess consumer works in windows	Mahendra M	More...				almost 12 years ago
Merge pull request #61 from mahendra/prod-windows	Mahendra M	More...				almost 12 years ago
Merge branch 'master' into prod-windows	Mahendra M	More...				almost 12 years ago

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