Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 111 to 120 from 261 (0.094s).
Loading phrases to help you
refine your search...
Re: code layout - Kafka - [mail # dev]
...I would vote for A just for simplicity of dependencies.On Sat, Feb 1, 2014 at 3:06 PM, Neha Narkhede wrote:> I like A. It will be simpler to maintain and evolve when we add the admin> ...
   Author: Guozhang Wang, 2014-02-03, 00:14
Re: New Producer Public API - Kafka - [mail # user]
...I think the most common motivate of having a customized partitioner is tomake sure some messages always go to the same partition, but people mayseldom want to know about which partition exac...
   Author: Guozhang Wang, 2014-02-03, 00:12
[KAFKA-1026] Dynamically Adjust Batch Size Upon Receiving MessageSizeTooLargeException - Kafka - [issue]
...Among the exceptions that can possibly received in Producer.send(), MessageSizeTooLargeException is currently not recoverable since the producer does not change the batch size but still retr...
http://issues.apache.org/jira/browse/KAFKA-1026    Author: Guozhang Wang, 2014-02-01, 20:30
Re: [Keeping equal no of messages in partitions ] - Kafka - [mail # user]
...Update the FAQ wiki page for this question:https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-Whydataisnotevenlydistributedamongpartitionswhenpartitioningkeyisnotspecified?On Fri, Jan...
   Author: Guozhang Wang, 2014-02-01, 18:32
Review Request 17524: Add one integration test for the new producer - Kafka - [mail # dev]
...-----------------------------------------------------------This is an automatically generated e-mail. To reply, visit:https://reviews.apache.org/r/17524/-------------------------------------...
   Author: Guozhang Wang, 2014-01-30, 02:24
Re: High Level Consumer delivery semantics - Kafka - [mail # user]
...Hi Clark,1. This is true, you need to synchronize these consumer threads whencalling commitOffsets();2. If you are asking what if the consumer thread crashed aftercurrentTopicInfo.resetConsu...
   Author: Guozhang Wang, 2014-01-30, 00:00
Re: Is there a way to delete partition at runtime? - Kafka - [mail # user]
...Hi Marc,Having a different set of metadata stored on the brokers to feed metadatarequests from producers and consumers would be very tricky I think. Foryour use case, one thing you could try...
   Author: Guozhang Wang, 2014-01-29, 20:13
Re: high-level consumer design - Kafka - [mail # user]
...To avoid some consumers not consuming anything, one small trick might bethat if a consumer found itself not getting any partition, it can force arebalancing by deleting its own registration ...
   Author: Guozhang Wang, 2014-01-29, 20:11
Re: [Using offset to fetch message][Need Help] - Kafka - [mail # user]
...In Kafka you cannot fetch just one message based on the offset, what youget instead is to start fetching from the given offset. Of course you canjust get the first one that you want and then...
   Author: Guozhang Wang, 2014-01-27, 22:15
[KAFKA-1055] BrokerTopicStats is updated before checking for MessageSizeTooLarge - Kafka - [issue]
...In Log.append function, BrokerTopicStats is updated before the checking for MessageSizeTooLarge, hence even if messages are refused at the server due to this exception, their counts would st...
http://issues.apache.org/jira/browse/KAFKA-1055    Author: Guozhang Wang, 2014-01-25, 02:00
Kafka (261)
mail # user (139)
mail # dev (77)
issue (45)
last 7 days (13)
last 30 days (51)
last 90 days (126)
last 6 months (210)
last 9 months (261)
Jun Rao (855)
Neha Narkhede (577)
"Neha Narkhede (412)
Jay Kreps (303)
"Jun Rao (277)
Joe Stein (162)
Joel Koshy (146)
Guozhang Wang (123)
John Fung (95)
"Joe Stein (94)
"Jay Kreps (90)
"Guozhang Wang (89)
Jason Rosenberg (68)
Swapnil Ghike (62)
David Arthur (61)