Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 81 to 90 from 653 (0.106s).
Loading phrases to help you
refine your search...
[KAFKA-170] Support for non-blocking polling on multiple streams - Kafka - [issue]
...Currently we provide a blocking iterator in the consumer. This is a good mechanism for consuming data from a single topic, but is limited as a mechanism for polling multiple streams.For exam...
http://issues.apache.org/jira/browse/KAFKA-170    Author: Jay Kreps, 2014-05-27, 17:00
Re: New consumer APIs - Kafka - [mail # user]
...Hey Eric,Yeah this is more similar to what we currently have but with a richer apithen a simple Iterator.I think the question is how the poll() on the various streams translatesinto the ulti...
   Author: Jay Kreps, 2014-05-17, 03:14
[expand - 3 more] - Re: Review Request 21398: Fix KAFKA-1445 v2 - Kafka - [mail # dev]
...Actually thinking about it this may not be a big deal as the comparison should short circuit on the == comparison. So for small sets of nodes this may be better.- JayThis is an automatically...
   Author: Jay Kreps, 2014-05-16, 19:15
Re: keyed-messages & de-duplication - Kafka - [mail # user]
...Hi,The compaction is done to clean-up space. It isn't done immediately onlyperiodically.I suspect the reason you see no compaction is that we never compact theactive segment of the log (the ...
   Author: Jay Kreps, 2014-05-14, 01:35
Re: 100 MB messages - Kafka - [mail # user]
...It can, but it will not perform very well. Kafka fully instantiatesmessages in memory (as a byte[] basically) so if you send a 100MB messagethe server will do a 100MB allocation to hold that...
   Author: Jay Kreps, 2014-05-14, 00:11
Re: Review Request 21304: Fix KAFKA-1445 - Kafka - [mail # dev]
...This is an automatically generated e-mail. To reply, visit:https://reviews.apache.org/r/21304/#review42734clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator....
   Author: Jay Kreps, 2014-05-12, 19:42
[KAFKA-1441] Purgatory purge causes latency spikes - Kafka - [issue]
...The request purgatory has a funky thing where it periodically loops over all watches and purges them. If you have a fair number of partitions you can accumulate lots of watches and purging t...
http://issues.apache.org/jira/browse/KAFKA-1441    Author: Jay Kreps, 2014-05-12, 17:33
Re: JAVA HEAP settings for KAFKA in production - Kafka - [mail # user]
...Hey Todd,Doc patch? :-)svn co http://svn.apache.org/repos/asf/kafka/site/081/Don't stress about html or formatting, I'm happy to do that part. I wouldlove to give people more authoritative a...
   Author: Jay Kreps, 2014-05-06, 17:32
Re: 0.7.1 Will there be any log info under poor network which packet may lose? - Kafka - [mail # user]
...TCP will attempt to resend until the packets are successfully delivered ora timeout occurs. So a packet loss should not lead to an error. The erroryou see in your log is the queue of unsent ...
   Author: Jay Kreps, 2014-05-05, 17:39
Re: 0.8.1 Java Producer API Callbacks - Kafka - [mail # user]
...This summary is correct. If you are just starting development now it isprobably reasonable to start with the new producer. We would certainlyappreciate any feedback on it.My recommendation w...
   Author: Jay Kreps, 2014-05-02, 17:08
Sort:
project
Kafka (653)
Avro (5)
HDFS (1)
type
mail # dev (287)
mail # user (248)
issue (118)
date
last 7 days (2)
last 30 days (13)
last 90 days (52)
last 6 months (111)
last 9 months (653)
author
Jun Rao (1013)
Neha Narkhede (644)
"Neha Narkhede (412)
Jay Kreps (337)
"Jun Rao (277)
Guozhang Wang (233)
Joel Koshy (201)
Joe Stein (198)
John Fung (95)
"Joe Stein (94)
"Jay Kreps (90)
"Guozhang Wang (89)
Jason Rosenberg (70)
Swapnil Ghike (62)
David Arthur (61)
"Sriram Subramanian (60)
None (60)
Chris Burroughs (58)
"Swapnil Ghike (52)
"John Fung (39)
"Joel Koshy (38)
Timothy Chen (32)
Sriram Subramanian (30)
Alan D. Cabrera (24)
"Jason Rosenberg (20)