| clear query|facets|time |
Search criteria: .
Results from 21 to 30 from
7408 (0.081s).
|
|
|
Loading phrases to help you refine your search...
|
|
Re: Update: RE: are commitOffsets botched to zookeeper? - Kafka - [mail # user]
|
|
...Have you considered abstracting offset storage away so people could implement their own? Would you take a patch if I'd stabbed at it, and if yes, what's the process (pardon the n00b)?KCBO,--...
|
|
|
Author: Alex Zuzin,
2013-05-17, 21:26
|
|
|
Re: Update: RE: are commitOffsets botched to zookeeper? - Kafka - [mail # user]
|
|
...to clarify, I meant that Robert could/should store the offsets in a fasterstore not that kafka should default to that :)Thanks NehaOn Fri, May 17, 2013 at 2:22 PM, Neha Narkhede wrote:> T...
|
|
|
Author: Scott Clasen,
2013-05-17, 21:26
|
|
|
Re: can producers(from same system) send messages to separate broker systems? - Kafka - [mail # user]
|
|
...Do you have any tests that measure that your high priority data is beingdelayed ? Assuming you are using 0.8, the end to end latency can be reducedby tuning some configs on the consumer (fet...
|
|
|
Author: Neha Narkhede,
2013-05-17, 21:26
|
|
|
Re: Update: RE: are commitOffsets botched to zookeeper? - Kafka - [mail # user]
|
|
...There is no particular need for storing the offsets in zookeeper. In factwith Kafka 0.8, since partitions will be highly available, offsets could bestored in Kafka topics. However, we haven'...
|
|
|
Author: Neha Narkhede,
2013-05-17, 21:23
|
|
|
Re: Setting a broker to be read-only? - Kafka - [mail # user]
|
|
...There is no easy way to do this in 0.7. If you are using a VIP to producedata to Kafka, you can remove that broker host from the VIP. It will stillbe available for consumer reads until it is...
|
|
|
Author: Neha Narkhede,
2013-05-17, 21:21
|
|
|
Re: Update: RE: are commitOffsets botched to zookeeper? - Kafka - [mail # user]
|
|
...afaik you dont 'have' to store the consumed offsets in zk right, this isonly automatic with some of the clients?why not store them in a data store that can write at the rate that yourequire?...
|
|
|
Author: Scott Clasen,
2013-05-17, 21:19
|
|
|
Re: Getting the latest message always from Kafka - Kafka - [mail # user]
|
|
...For every unit test, you want your server and consumer to start fresh. Inyour unit test, you maintain state in the KafkaManager across unit tests soyour tests don't work as expected. Try mov...
|
|
|
Author: Neha Narkhede,
2013-05-17, 21:17
|
|
|
Re: Our use case and am I right in my definition of Throughput? - Kafka - [mail # user]
|
|
...Another parameter that you want to tune if you want higher throughput in0.7 is the broker side flush interval. If you set it to something high,like 50K or 100K, you can maximize the throughp...
|
|
|
Author: Neha Narkhede,
2013-05-17, 21:14
|
|
|
[KAFKA-909] Provide support in the producer to specify a stateful instance of an Encoder, like the consuemr allows with the Decoder - Kafka - [issue]
|
|
...It is very useful to have a shared instance of the Encoder, to do advanced encoding. The consumer allows the ability to set the Decoder instance and achieve this capability. The ...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-909
Author: Rob Withers,
2013-05-17, 18:53
|
|
|
Re: InvalidMessageException problems - Kafka - [mail # user]
|
|
...Turns out it was OpenJDK on the AWS AMI instance. As soon as I replacedOpenJDK:java version "1.6.0_24"OpenJDK Runtime Environment (IcedTea6 1.11.11)(amazon-61.1.11.11.53.amzn1-x86_64)OpenJDK...
|
|
|
Author: Jason Weiss,
2013-05-17, 18:00
|
|
|
|