Re: what response does broker send when there is not message on the partition

2015-04-21 Thread Alexey Borschenko
able on the partition. Why would you need it to? > > On Mon, Apr 20, 2015 at 3:46 AM, Alexey Borschenko > wrote: > >> You can also send a FetchOffsetRequest and check for the last > >> available offset (log end offset) - this way you won't have to send a > >> fet

SimpleConsumer.getOffsetsBefore

2015-04-20 Thread Alexey Borschenko
Does *SimpleConsumer.getOffsetsBefore* takes in account consumer group specific offsets? I need to be able to get offsets closest to specified timestamp per topic-consumerGroup. Is there any way to achieve this using Kafka API ? Thanx!

Re: what response does broker send when there is not message on the partition

2015-04-20 Thread Alexey Borschenko
> You can also send a FetchOffsetRequest and check for the last > available offset (log end offset) - this way you won't have to send a > fetch request that is likely to fail. Does this takes in account specific consumer offsets stored in Zookeeper? On Fri, Apr 17, 2015 at 5:57 PM, Gwen Shapira

SimpleConsumer.getOffsetsBefore problem

2015-04-16 Thread Alexey Borschenko
Hi all! I need to read offsets closing to specified timestamp. As I can see this can be achieved by using SImpleConsumer API. To test things I use SimpleConsumer example provided on site: https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example I use Kafka 8.2.1 When I pass