| clear query|facets|time |
Search criteria: .
Results from 1 to 10 from
1175 (0.134s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: OffsetOutOfRangeException and getOffsetsBefore - Kafka - [mail # user]
|
|
...This gives you back two valid offsets, not a range.Thanks,JunOn Fri, May 24, 2013 at 11:29 AM, Sining Ma wrote:> Hi,> We are currently using kafka-0.7.1 right now.> I have two...
|
|
|
Author: Jun Rao,
2013-05-25, 05:09
|
|
|
[KAFKA-920] zkclient jar 0.2.0 is not compatible with 0.1.0 - Kafka - [issue]
|
|
...Just realized that zkclient 0.2.0 introduced a non-backward compatible api. In 0.1.0, it has public void writeData(java.lang.String path, java.lang.Object datat) ...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-920
Author: Jun Rao,
2013-05-24, 22:48
|
|
|
Re: [0.8] Autocommit bug? Or am I doing it wrong? :) - Kafka - [mail # user]
|
|
...This turns out to be a bug. It seems that we always call commitOffsets() inZookeeperConsumerConnector.closeFetchersForQueues() (which is called duringrebalance), whether auto commit is enabl...
|
|
|
Author: Jun Rao,
2013-05-24, 16:33
|
|
|
Re: large amount of disk space freed on restart - Kafka - [mail # user]
|
|
...I haven't seen this issue before. We do have ~1K topics in one of the Kafkaclusters at LinkedIn.Thanks,JunOn Thu, May 23, 2013 at 11:05 AM, Jason Rosenberg wrote:> Yeah, that's what...
|
|
|
Author: Jun Rao,
2013-05-24, 03:56
|
|
|
Re: large amount of disk space freed on restart - Kafka - [mail # user]
|
|
...Jason,Kafka closes the handler of all delete files. Otherwise, the broker willrun out of file handler quickly.Thanks,JunOn Wed, May 22, 2013 at 10:17 PM, Jason Rosenberg wrote:> So,...
|
|
|
Author: Jun Rao,
2013-05-23, 14:15
|
|
|
Re: Apache Kafka in AWS - Kafka - [mail # user]
|
|
...Jason,Unfortunately, Apache mailing lists don't support attachments. Could youdocument your experience (with the graphs) in a blog (or a wiki page inKafka)?Thanks,JunOn Thu, May 23, 2013 at ...
|
|
|
Author: Jun Rao,
2013-05-23, 14:11
|
|
|
Re: consumer offset not saved in zk - Kafka - [mail # user]
|
|
...You are looking at the wrong path in ZK. The correct path for consumeroffset is /consumers/[groupId]/offsets/[topic]/[partitionId] -> long(offset). For more details on our ZK layout, seeh...
|
|
|
Author: Jun Rao,
2013-05-23, 14:08
|
|
|
Re: Apache Kafka in AWS - Kafka - [mail # user]
|
|
...Jason,Thanks for sharing. This is very interesting. Normally, Kafka brokers don'tuse too much CPU. Are most of the 750% CPU actually used by Kafka brokers?JunOn Wed, May 22, 2013 at 6:11 PM,...
|
|
|
Author: Jun Rao,
2013-05-23, 04:17
|
|
|
[KAFKA-907] controller needs to close socket channel to brokers on exception - Kafka - [issue]
|
|
...When the controller sends a request to a broker (e.g., leaderAndIsrRequest), it may hit a exception (e.g. SocketTimeException). When this happens, the socket channel needs to be closed and r...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-907
Author: Jun Rao,
2013-05-23, 00:31
|
|
|
Re: produce request wire format question - Kafka - [mail # dev]
|
|
...Dave,Currently, the broker expects each producer request to specify the exactpartition id (-1 is on longer valid). The mapping from a message to apartition is done at the producer client. Th...
|
|
|
Author: Jun Rao,
2013-05-22, 16:28
|
|
|
|
