Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 81 to 90 from 132 (0.071s).
Loading phrases to help you
refine your search...
[KAFKA-602] A ConsumerConnector that never receives messages does not shutdown cleanly - Kafka - [issue]
...Working with the latest trunk version (last commit was on 10/9/2012).If I create a consumer connector, and create some KafkaStreams using a TopicFilter, but then never send any messages, and...
http://issues.apache.org/jira/browse/KAFKA-602    Author: Jason Rosenberg, 2013-06-05, 20:24
Re: Compression in kafka 0.8 - Kafka - [mail # user]
...In this case, does the consumer code need to change, account for thecompression (or is this handled automatically in the consumer apis?).If we decide to start compressing messages to a topic...
   Author: Jason Rosenberg, 2013-06-05, 07:14
[KAFKA-899] LeaderNotAvailableException the first time a new message for a partition is processed. - Kafka - [issue]
...I'm porting some unit tests from 0.7.2 to 0.8.0.  The test does the following, all embedded in the same java process:-- spins up a zk instance-- spins up a kafka server using a fres...
http://issues.apache.org/jira/browse/KAFKA-899    Author: Jason Rosenberg, 2013-05-31, 06:18
async producer and new ack levels - Kafka - [mail # user]
...With 0.8, we now have ack levels when sending messages.  I'm wondering howthis applies when sending messages in async mode.  Are there any guaranteesat least that each async batch ...
   Author: Jason Rosenberg, 2013-05-31, 04:50
[KAFKA-900] ClosedByInterruptException when high-level consumer shutdown normally - Kafka - [issue]
...I'm porting some unit tests from 0.7.2 to 0.8.0. The test does the following, all embedded in the same java process: -- spins up a zk instance -- spins up a kafka server using a fresh lo...
http://issues.apache.org/jira/browse/KAFKA-900    Author: Jason Rosenberg, 2013-05-29, 17:56
Re: Producer can't initialize if zk host down (0.7.2) - Kafka - [mail # user]
...Thanks Neha,I see now that is true.  It looks like it just needs to resolve all thehosts (but doesn't need zk to be available on each host).  Sodecommissioning a zknode (and removi...
   Author: Jason Rosenberg, 2013-05-21, 22:05
Re: heterogenous kafka cluster? - Kafka - [mail # user]
...Letting each broker have a weight sounds like a great idea.Since in my use case, topics are generally auto-created, it won't bepractical to map brokers manually per topic.Thanks,JasonOn Fri,...
   Author: Jason Rosenberg, 2013-05-18, 06:28
Re: a build jar request - Kafka - [mail # user]
...A maven snapshot repo would be ideal for this....On Fri, May 10, 2013 at 6:02 PM, Rob Withers  wrote:> ps.  Is there a way to determine the build of a jar?>> From: Rob Wit...
   Author: Jason Rosenberg, 2013-05-11, 01:52
Re: can the replication factor for a topic be changed after it's created? - Kafka - [mail # user]
...so does that, thereby, allow you to increase the replication for apartition?On Wed, May 8, 2013 at 10:48 PM, Neha Narkhede wrote:> If you add more brokers to an existing cluster, you can ...
   Author: Jason Rosenberg, 2013-05-09, 06:52
Re: Can't connect to a server if not enough partitions - Kafka - [mail # user]
...Neha,Thanks, I think I did understand what was going (despite the errormessage).  And my question stands, if a broker is momentarily down,shouldn't we still be able to create a topic? &...
   Author: Jason Rosenberg, 2013-05-09, 06:51
Kafka (132)
Sqoop (3)
mail # user (105)
issue (23)
mail # dev (4)
last 7 days (2)
last 30 days (5)
last 90 days (7)
last 6 months (10)
last 9 months (132)
Jun Rao (968)
Neha Narkhede (624)
"Neha Narkhede (412)
Jay Kreps (327)
"Jun Rao (277)
Guozhang Wang (202)
Joe Stein (180)
Joel Koshy (179)
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)