Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
clear query|facets|time Search criteria: .   Results from 101 to 110 from 1764 (0.264s).
Loading phrases to help you
refine your search...
[expand - 1 more] - Re: kafka web console running error - Kafka - [mail # user]
...You will need to contact the owner of that project directly.Thanks,JunOn Thu, Nov 27, 2014 at 11:40 AM, Sa Li  wrote: ...
   Author: Jun Rao, 2014-11-29, 16:31
Re: how many brokers to set in kafka - Kafka - [mail # user]
...Typically, you will just have one broker per server. If you do want to setup multiple brokers on the same server, ideally you need to give eachbroker dedicated storage.Thanks,JunOn Thu, Nov ...
   Author: Jun Rao, 2014-11-29, 16:30
Re: Does adding ConsumerTimeoutException make the code more robust? - Kafka - [mail # user]
...By default, it.hasNext() blocks when there is no more message to consume.So catching ConsumerTimeoutException doesn't make any difference. You onlyneed to handle ConsumerTimeoutException if ...
   Author: Jun Rao, 2014-11-29, 16:26
Re: Kafka 0.8.2 log cleaner - Kafka - [mail # user]
...Yes, log cleaner is in 0.8.2. You just need to set the retention policy ofa topic to "compact".Thanks,JunOn Thu, Nov 27, 2014 at 5:20 AM, Khandygo, Evgeny (EXT) <[EMAIL PROTECTED]> wro...
   Author: Jun Rao, 2014-11-29, 16:24
Re: Partition key not working properly - Kafka - [mail # user]
...The issue is probably the hashcode of byte[] is based on reference, insteadof the value. You can try binding the producer to [Array[byte],Array[byte]]and using ByteArrayPartitioner. Alternat...
   Author: Jun Rao, 2014-11-27, 01:19
Re: Partition id of consumed message? - Kafka - [mail # user]
...Yes, the consumer iterator returns MessageAndMetadata which contains amethod partition().Thanks,JunOn Wed, Nov 26, 2014 at 10:40 AM, Palur Sandeep wrote: ...
   Author: Jun Rao, 2014-11-27, 00:33
Re: dynamically changing log level on a running broker? - Kafka - [mail # user]
...You can do this through jconsole on the log4j mbean.Thanks,JunOn Tue, Nov 25, 2014 at 2:56 AM, ben fleis  wrote: ...
   Author: Jun Rao, 2014-11-26, 02:50
[expand - 1 more] - Re: Does Kafka Producer service ? - Kafka - [mail # user]
...Assuming that you use a single producer in the async mode, the Kafkaoverhead should be limited to a single thread. Using a cheaper compressioncodec such as snappy will also help reducing the...
   Author: Jun Rao, 2014-11-26, 02:48
[expand - 1 more] - Re: Exception in thread "main" java.lang.ExceptionInInitializerError - Kafka - [mail # user]
...It seems you hit an exception when instantiating the sfl4j logger insidethe producer.Thanks,JunOn Sun, Nov 23, 2014 at 9:29 PM, Haoming Zhang wrote: ...
   Author: Jun Rao, 2014-11-25, 05:51
Re: issues using the new 0.8.2 producer - Kafka - [mail # user]
...1. The new producer takes only the new producer configs.2. There is no longer a pluggable partitioner. By default, if a key isprovided, the producer hashes the bytes to get the partition. Th...
   Author: Jun Rao, 2014-11-25, 05:34
Sort:
project
Kafka (1764)
Cassandra (27)
Zookeeper (17)
Avro (5)
Hadoop (3)
type
mail # user (1205)
mail # dev (287)
issue (272)
date
last 7 days (27)
last 30 days (71)
last 90 days (155)
last 6 months (277)
last 9 months (1764)
author
Jun Rao (1034)
Neha Narkhede (563)
Neha Narkhede (412)
Jay Kreps (327)
Guozhang Wang (277)
Jun Rao (276)
Joe Stein (242)
Joel Koshy (182)
John Fung (95)
Joe Stein (94)
Jay Kreps (89)
Guozhang Wang (88)
Jason Rosenberg (77)
Sriram Subramanian (60)
None (60)
Chris Burroughs (58)
David Arthur (58)
Swapnil Ghike (58)
Swapnil Ghike (51)
Gwen Shapira (45)
John Fung (39)
Joel Koshy (38)
Sriram Subramanian (27)
Alan D. Cabrera (24)
Bhavesh Mistry (24)
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB