Re: OffsetOutOfRangeException and getOffsetsBefore

2013-05-24 Thread Sining Ma
? -- Regards Sining Ma -Original Message- From: Suyog Rao To: users Sent: Fri, May 24, 2013 1:32 pm Subject: Re: OffsetOutOfRangeException and getOffsetsBefore Since you are using the simple consumer you will need to handle the OffsetOutOfRange Exception in your code. This

OffsetOutOfRangeException and getOffsetsBefore

2013-05-24 Thread Sining Ma
, this function returns an array [offset1, offset2]. Does this mean from offset1 to offset2 are valid, and offset2 to current offset are valid? We are confused about the meaning of this array. -- Regards Sining Ma

Kafka producer sends messages efficiency

2013-05-06 Thread Sining Ma
time and improve the efficiency for sending messages through kafka producer. -- Regards Sining Ma

Fwd: kafka appender layout does not work for kafka 0.7.1

2013-03-29 Thread Sining Ma
Hi I am using kafka 0.7.1 right now. I am using the following log4j properties file and trying to send some log information to kafka server. log4j.rootLogger=INFO,file,stdout log4j.appender.stdout=org.apache.log4j.ConsoleAppender log4j.appender.stdout.layout=org.apache.log4j.PatternLayout

generate message consumers as kafka server threads

2013-03-01 Thread Sining Ma
pass some flags to kafka server to invoke this functionality? -- Regards, Sining Ma

Re: Question about function SimpleConsumer.getOffsetsBefore

2013-02-25 Thread Sining Ma
If right now this function can return many offsets, will it take long time? Based on your experience, what is the best value for maxNumOffsets? Thanks, Sining Ma On Mon, Feb 25, 2013 at 5:24 PM, Neha Narkhede wrote: > The value of maxNumOffsets depends on what you are trying to accomplish.

Question about function SimpleConsumer.getOffsetsBefore

2013-02-25 Thread Sining Ma
time. Right now I set it to 10, but I am not sure if this is a good value. Is there any advice how to set the value of maxNumOffsets? -- Regards, Sining Ma