| clear query|facets|time |
Search criteria: .
Results from 1 to 10 from
1162 (0.369s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: scala questions - Kafka - [mail # user]
|
|
...Scala compiles to java bytecode. You can use java objects in scala and viceversa.Thanks,JunOn Fri, May 17, 2013 at 4:48 PM, Rob Withers wrote:> I've gotten to know y'all a bit, so I...
|
|
|
Author: Jun Rao,
2013-05-18, 03:44
|
|
|
Re: API to to query messages amount under one topic - Kafka - [mail # user]
|
|
...Yes, that's probably what you are looking for. It tells you the # ofunconsumed messages per partition, for a particular consumer.Thanks,JunOn Fri, May 17, 2013 at 4:52 PM, Rob Withers ...
|
|
|
Author: Jun Rao,
2013-05-18, 03:40
|
|
|
Re: heterogenous kafka cluster? - Kafka - [mail # user]
|
|
...In 0.8, you can create topics manually and explicitly specify the replicato broker mapping. Post 0.8, we can think of some more automated ways todeal with this (e.g., let each broker carry s...
|
|
|
Author: Jun Rao,
2013-05-18, 03:38
|
|
|
Re: InvalidMessageException problems - Kafka - [mail # user]
|
|
...This indicates the messages sent to the broker are corrupted. Typically,this is because either the producer sends the corrupted data somehow or thenetwork is flaky. Are you using a java prod...
|
|
|
Author: Jun Rao,
2013-05-17, 15:18
|
|
|
Re: Our use case and am I right in my definition of Throughput? - Kafka - [mail # user]
|
|
...You earlier email seems to focus on latency, not throughput. Typically, youcan either optimize for latency or throughput, but not both. If you wanthigher throughput, you should consider usin...
|
|
|
Author: Jun Rao,
2013-05-17, 15:11
|
|
|
Re: Time difference between message fetch and message send is very high (~900-1200ms) - Kafka - [mail # user]
|
|
...There are mainly 2 things to consider for latency. (1) How quickly does theproducer send the message to the broker? If you use the sync mode in theproducer, the message will be sent immediat...
|
|
|
Author: Jun Rao,
2013-05-17, 15:07
|
|
|
Re: could an Encoder/Decoder be stateful? - Kafka - [mail # user]
|
|
...Possible, but definitely a post 0.8 item. If you are interested, could youfile a jira to track this?Thanks,JunOn Thu, May 16, 2013 at 10:06 PM, Rob Withers wrote:> Could the produce...
|
|
|
Author: Jun Rao,
2013-05-17, 14:53
|
|
|
Re: API to to query messages amount under one topic - Kafka - [mail # user]
|
|
...For monitoring, we have jmxs on the broker for both the message and thebyte rate.Thanks,JunOn Thu, May 16, 2013 at 10:04 PM, Rob Withers wrote:> Immediately monitoring. Later,...
|
|
|
Author: Jun Rao,
2013-05-17, 14:52
|
|
|
Re: could an Encoder/Decoder be stateful? - Kafka - [mail # user]
|
|
...The encoder instance can't be shared in different producers since it'sinstantiated through java reflection. Decoder instance can actually beshared by different consumers since it's passed in...
|
|
|
Author: Jun Rao,
2013-05-17, 04:04
|
|
|
Re: API to to query messages amount under one topic - Kafka - [mail # user]
|
|
...What do you plan to use this information for?Thanks,JunOn Thu, May 16, 2013 at 5:57 AM, Withers, Robert wrote:> Any possibility for a queuedMessageCount(topic, partitionNumber) protocol?&...
|
|
|
Author: Jun Rao,
2013-05-17, 04:00
|
|
|
|
