Home | About | Sematext search-lucene.com search-hadoop.com
clear query|facets|time Search criteria: .   Results from 171 to 180 from 1725 (0.089s).
Loading phrases to help you
refine your search...
Re: Kafka: writing custom Encoder/Serializer - Kafka - [mail # user]
...The customized encoder/decoder has to have a constructor that takes(VerifiableProperties: props). Alternatively, you could do theencoding/decoding outside of Kafka client and just send byte[...
   Author: Jun Rao, 2014-05-20, 14:41
Re: SocketServerStats not reporting bytes written or read - Kafka - [mail # user]
...Is the problem with the jmx beans themselves or jmxstats?Thanks,JunOn Mon, May 19, 2014 at 2:48 PM, Xuyen On  wrote: ...
   Author: Jun Rao, 2014-05-20, 04:45
[expand - 2 more] - Re: Question about recovering from outage - Kafka - [mail # user]
...In trunk, we have a JMX monitoring the states of each broker. One of thestates is log recovery.Thanks,JunOn Mon, May 19, 2014 at 11:15 AM, Jonas Bergström wrote: ...
   Author: Jun Rao, 2014-05-20, 04:39
Re: Kafka Migration Tool - Kafka - [mail # user]
...It seems that you may have set the zk connection string to one used by 0.8Kafka brokers.Thanks,JunOn Mon, May 19, 2014 at 8:34 AM, Mo Firouz  wrote: ...
   Author: Jun Rao, 2014-05-20, 04:37
Re: Make kafka storage engine pluggable and provide a HDFS plugin? - Kafka - [mail # dev]
...Which version of Kafka are you using? Cluster expansion should be reliablein 0.8.1.1.As for using HDFS, we thought about it when implement replication in Kafka.The short answer is that using...
   Author: Jun Rao, 2014-05-19, 14:59
[expand - 2 more] - Re: Controller to broker connection timing out through load balancer - Kafka - [mail # user]
...Perhaps you will have to lower the tcp alive interval to avoid the socketconnection from being killed.Thanks,JunOn Fri, May 16, 2014 at 2:12 PM, Robin Yamaguchi wrote: ...
   Author: Jun Rao, 2014-05-19, 04:32
Re: [0.7.2] see ZkEventThread triggered when these is no broker change - Kafka - [mail # user]
...Do you see ZK session expiration in the log?Thanks,JunOn Fri, May 16, 2014 at 8:06 PM, Mingmin Liu wrote: ...
   Author: Jun Rao, 2014-05-19, 04:28
[expand - 1 more] - Re: who is using kafka to stare large messages? - Kafka - [mail # user]
...You just need to make sure that fetch size is larger than max.message.sizeset in the brokers.Thanks,JunOn Thu, May 15, 2014 at 3:55 PM, MB JA  wrote: ...
   Author: Jun Rao, 2014-05-17, 16:30
[expand - 1 more] - Re: New consumer APIs - Kafka - [mail # user]
...Eric,With the new proposal, it seems what you want can be achieved by justinstantiating N Consumer instances. Then, you can wrap each in a thread andcall poll() in it. Will that work for you...
   Author: Jun Rao, 2014-05-17, 15:48
[expand - 1 more] - Re: NFS and/or local filesystem consumer? - Kafka - [mail # user]
...Ken,We don't have sth like that now. It shouldn't be too hard to write onethough. You probably need some kind of time-based partitioning to differentfiles.Thanks,JunOn Fri, May 16, 2014 at 4...
   Author: Jun Rao, 2014-05-17, 15:40
Sort:
project
Kafka (1725)
Cassandra (27)
Zookeeper (17)
Avro (3)
Hadoop (3)
type
mail # user (1034)
mail # dev (449)
issue (242)
date
last 7 days (12)
last 30 days (57)
last 90 days (159)
last 6 months (423)
last 9 months (1725)
author
Jun Rao (989)
Neha Narkhede (630)
"Neha Narkhede (412)
Jay Kreps (330)
"Jun Rao (277)
Guozhang Wang (221)
Joel Koshy (198)
Joe Stein (181)
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)