Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 1 to 10 from 11 (0.171s).
Loading phrases to help you
refine your search...
Re: how to keep the same partition when using mirror maker - Kafka - [mail # user]
...Thanks Jun.GuodongOn Wed, Jul 3, 2013 at 12:53 PM, Jun Rao  wrote:> One of the issues is that in 0.7, the partitioning key is not stored on the> broker. So, mirror maker won't kno...
   Author: 王国栋, 2013-07-03, 07:47
Re: InvalidMessageException - Kafka - [mail # user]
...Hi Yonghui,We see this exception too. We believe this is related to the jdk versions.In our case, the exception only happens on heavy workload, and after weupgrade the jdk version , it is go...
   Author: 王国栋, 2013-05-30, 04:43
Re: Question about Partitions not receive equal number messages - Kafka - [mail # user]
...Hi Neha,We can not understand why the partitions will be unbalanced if each threadgets different number of messages.We go through the code of producer, and the partition number is generatedb...
   Author: 王国栋, 2013-04-17, 14:48
Re: no logs received when a broker restart after clearing its logs - Kafka - [mail # user]
...Thanks Neha.Yes, I believe we run into this issue.We will try this patch. Currently,  make topic-partition directory manuallyis OK for us.GuodongOn Wed, Apr 17, 2013 at 9:24 PM, Neha Na...
   Author: 王国栋, 2013-04-17, 14:41
Re: Kafka throw InvalidMessageException and lost data - Kafka - [mail # user]
...Hi Neha,I am sorry, we couldn't find the detail reason of this bug. But we dobelieve that the bug is in java.nio package. Something bad may happenduring sync-producer sends data in byteBuffe...
   Author: 王国栋, 2013-03-25, 04:23
Re: how to configure zk.connect in 0.7.2 - Kafka - [mail # user]
...Thanks Jun. It works~On Wed, Mar 13, 2013 at 1:14 AM, Jun Rao  wrote:> You should set it to the following, with namespace only specified at the> end:> zk8sh.prod.mediav.com:219...
   Author: 王国栋, 2013-03-13, 03:21
Re: Graceful termination of kafka broker after draining all the data consumed - Kafka - [mail # user]
...Thanks Jun. I will check more info about 0.8On Tue, Feb 19, 2013 at 12:51 AM, Jun Rao  wrote:> In 0.7, it's not very easy to decommission a broker using ZK based> producers. It's ...
   Author: 王国栋, 2013-02-19, 01:41
MirrorMaker tool hangs up when producer throw an Exception - Kafka - [mail # user]
...Hi ,When the producer in the MirrorMaker tool throws exceptions, I can find oneof the  streaming threads stops, but the mirror make process hangs up. Itseems that the consumer threads a...
   Author: 王国栋, 2013-02-07, 08:02
Re: ASyncProducer loss more messages than SyncProducer when broker crashes. - Kafka - [mail # user]
...Thanks Jun.On Tue, Feb 5, 2013 at 5:03 PM, Jun Rao  wrote:> It could be. This is because it takes ZK up to 6 secs to detect the failure> due to a hard kill (since ZK client is not...
   Author: 王国栋, 2013-02-05, 12:55
Re: How does a new broker decide the partitions of the topic? - Kafka - [mail # user]
...Thanks yonghui.That makes sense.On Mon, Dec 31, 2012 at 1:45 AM, 永辉 赵  wrote:> Partition name registered in zk contains broker id and sequence(partition)> id, such as "0-0", "0-1"...
   Author: 王国栋, 2012-12-31, 16:36
Kafka (11)
Sqoop (2)
mail # user (11)
last 7 days (0)
last 30 days (0)
last 90 days (0)
last 6 months (0)
last 9 months (11)
Jun Rao (969)
Neha Narkhede (624)
"Neha Narkhede (412)
Jay Kreps (327)
"Jun Rao (277)
Guozhang Wang (204)
Joe Stein (180)
Joel Koshy (178)
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)