Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 1 to 9 from 9 (0.053s).
Loading phrases to help you
refine your search...
[KAFKA-419] Updated PHP client library to support kafka 0.7+ - Kafka - [issue]
...I updated the PHP client library to fully work with the kafka code in trunk, with the following improvements:- added support for GZIP compression (both in the producer and the consumer);- im...
http://issues.apache.org/jira/browse/KAFKA-419    Author: Lorenzo Alberton, 2013-04-04, 21:42
[KAFKA-761] Fetch request randomly returns 0 bytes when there's still data in the log - Kafka - [issue]
...I can't track the bug down in the code, but the behaviour has been hitting us for quite some time (on Kafka 0.7.2): sometimes, a new Simple Consumer object, on a new Fetch Request, retur...
http://issues.apache.org/jira/browse/KAFKA-761    Author: Lorenzo Alberton, 2013-03-08, 18:27
Re: Regarding C++ Consumer in Kafka - Kafka - [mail # user]
...Small correction, the PHP client is now able to interact with ZK, and offers a high level API. The C++ consumer is only implementing the lower level API (and was written against Kafka 0.05)....
   Author: Lorenzo Alberton, 2012-09-24, 15:27
Re: [VOTE] Release Kafka 0.7.2-incubating (Candidate 1) - Kafka - [mail # dev]
...It's probably better to remove the client libraries and add a README with a link to this wiki page:  https://cwiki.apache.org/confluence/display/KAFKA/Kafka+non-java+clients   On T...
   Author: Lorenzo Alberton, 2012-09-22, 22:17
[expand - 2 more] - Re: 0.7.2 release - Kafka - [mail # dev]
...The c++ client in kafka/clients/cpp is another one we contributed, and probably only works with the 0.05 release. Please send me a link to the new wiki page when created, I'll update it with...
   Author: Lorenzo Alberton, 2012-09-19, 07:34
Non-blocking socket when queue has no new data - Kafka - [mail # dev]
...Hi,  I have a question about non-blocking connections.  passes it on to a Processor thread. The connection by default is blocking, i.e. the consumer sends the fetch request and the...
   Author: Lorenzo Alberton, 2012-08-07, 22:45
[expand - 1 more] - Re: Thousands of topics - Kafka - [mail # user]
...Hi Taylor,  thanks for your reply. I'd love to read your blog post about your experiences with it, especially around hardware configuration and how you consume the data (few/many short/...
   Author: Lorenzo Alberton, 2012-08-07, 21:47
[KAFKA-406] Gzipped payload is a fully wrapped Message (with headers), not just payload - Kafka - [issue]
...When creating a gzipped MessageSet, the collection of Messages is passed to CompressionUtils.compress(), where each message is serialised [1] into a buffer (not just the payload, the full Me...
http://issues.apache.org/jira/browse/KAFKA-406    Author: Lorenzo Alberton, 2012-07-26, 17:44
[KAFKA-407] Uncaught InputStream.close() exception in CompressionUtils.compress() - Kafka - [issue]
...In CompressionUtils.compress(), in this try/catch block:==========try {      cf.write(messageByteBuffer.array)    } catch {   ...
http://issues.apache.org/jira/browse/KAFKA-407    Author: Lorenzo Alberton, 2012-07-22, 21:47
Kafka (9)
issue (4)
mail # dev (3)
mail # user (2)
last 7 days (0)
last 30 days (0)
last 90 days (0)
last 6 months (0)
last 9 months (9)
Jun Rao (1035)
Neha Narkhede (657)
Neha Narkhede (412)
Jay Kreps (348)
Jun Rao (276)
Guozhang Wang (246)
Joe Stein (213)
Joel Koshy (207)
John Fung (95)
Joe Stein (94)
Guozhang Wang (89)
Jay Kreps (89)
Jason Rosenberg (70)
Swapnil Ghike (62)
David Arthur (61)
Sriram Subramanian (60)
None (60)
Chris Burroughs (58)
Swapnil Ghike (51)
John Fung (39)
Joel Koshy (38)
Timothy Chen (32)
Sriram Subramanian (30)
Alan D. Cabrera (24)
Gwen Shapira (24)
Lorenzo Alberton