0
I Use This!
Inactive

Commits : Listings

Analyzed about 3 hours ago. based on code collected 1 day ago.
Jun 13, 2025 — Jun 13, 2026
Commit Message Contributor Files Modified Lines Added Lines Removed Code Location Date
Merge pull request #20 from michaelbutler/mbutler/fix-infinite-loop More... about 6 years ago
Remove E_NOTICE check and return false for any other problem More... almost 7 years ago
Use pre-set buflen instead of strlen(buf) More... almost 7 years ago
Update some PHPDoc blocks More... almost 7 years ago
Implement temporary error handler to catch broken pipes More... almost 7 years ago
use valid SPDX license identifier
Lorenzo Alberton
as quipo
More... almost 8 years ago
Merge pull request #15 from saji89/patch-1 More... over 10 years ago
Update working link for Kafka hompage More... over 10 years ago
Merge pull request #14 from mpitid/master More... almost 11 years ago
Check for a valid socket before setting options More... almost 11 years ago
Specify kafka version More... about 11 years ago
Merge pull request #11 from mheap/master More... about 11 years ago
New: Added composer.json More... about 11 years ago
Merge pull request #10 from adrienbrault/patch-1 More... over 11 years ago
Add php syntax highlighting to README More... over 11 years ago
Merge pull request #9 from benblack86/configurable-timeouts More... almost 12 years ago
Fixed indentaion More... almost 12 years ago
Merge pull request #8 from benblack86/configurable-timeouts More... almost 12 years ago
Allow timeouts to be passed from Producer More... almost 12 years ago
Merge pull request #7 from shyamalprasad/largebuf More... over 12 years ago
Allow arbitrary number of fread calls when receiving large data packets. More... over 12 years ago
Merge pull request #6 from shyamalprasad/largebuf More... over 12 years ago
Complete message write to socket when socket cannot accept all bytes. More... over 12 years ago
especially when connecting to a remote kafka host, some fread() calls might return an empty buffer since the data has not yet arrived: this does not mean the connection is broken or the batch delivery failed. Ideally, we should use a select() call on the socket to detect activity before fread(), or use blocking mode on the socket if we have a persistent connection to kafka (as opposed to hit-and-run polling)
Lorenzo Alberton
as quipo
More... about 13 years ago
Update consume.php More... about 13 years ago
Fixed issue #1: GetOffsetRequest return negative offset on PHP5.2 where offset > 2^32
Lorenzo Alberton
as quipo
More... about 13 years ago
reuse consumer
Lorenzo Alberton
as quipo
More... over 13 years ago
reset iterators; catch exceptions; detect when kafka is lying (i.e. returning 0 bytes but there is data left in the buffer)
Lorenzo Alberton
as quipo
More... over 13 years ago
close socket on exception
Lorenzo Alberton
as quipo
More... over 13 years ago
close socket on exception; better detection of EOF vs. EOB
Lorenzo Alberton
as quipo
More... over 13 years ago