What's code in line 164 of SimpleConsumerClient.getLastOffset()?

Thanks,

Jun


On Fri, Aug 22, 2014 at 7:36 AM, chenlax <lax...@hotmail.com> wrote:

> kafka version is 0.8.0, the code as
> https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example
>
> when i assign a offset ,it will throw
> java.lang.ArrayIndexOutOfBoundsException: 0
>
> java.lang.ArrayIndexOutOfBoundsException: 0
>         at
> com.chen.test.consumer.SimpleConsumerClient.getLastOffset(SimpleConsumerClient.java:164)
>         at
> com.chen.test.consumer.SimpleConsumerClient.run(SimpleConsumerClient.java:80)
>         at
> com.chen.test.consumer.SimpleConsumerClient.main(SimpleConsumerClient.java:48)
> ##EarliestTime : -2 || -1 #### The Start Offset : -2
> Error fetching data from the Broker:10.209.22.206 Reason: 1
>
> how can is get the message which is assign offset?
>
> Thanks,
> Lax
>

Reply via email to