| clear query|facets|time |
Search criteria: .
Results from 101 to 110 from
1258 (0.119s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: Closing socket connections during extended message delivery - Kafka - [mail # user]
|
|
...In 0.7, each producer reconnects to the broker periodically. Take a look atreconnect.interval in http://kafka.apache.org/07/configuration.htmlThanks,JunOn Tue, May 21, 2013 at 7:35 AM, Jason...
|
|
|
Author: Jun Rao,
2013-05-21, 15:08
|
|
|
Re: About Kafka Users Group around Hadoop Summit - Kafka - [mail # user]
|
|
...Yes, we can have a Kafka user group meeting then. We could do this in oneof the evenings (Tue, Wed, or Thu). What will people prefer?Also, there will be a Kafka talk in Hadoop summit too.Tha...
|
|
|
Author: Jun Rao,
2013-05-21, 04:05
|
|
|
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
|
|
|
|
