Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> auto.offset.reset in kafka 0.8


Copy link to this message
-
Re: auto.offset.reset in kafka 0.8
Not sure that I fully understand your problem. Could you attach the
exception that you saw?

Thanks,

Jun
On Mon, Jul 1, 2013 at 12:50 AM, Martin Eigenbrodt <
[EMAIL PROTECTED]> wrote:

> Hi there,
>
> I am using kafka 0.8 (currently 0.8.0-beta1-candidate1) and I want my
> consumer to fail if it can not reliably find out the last consumed offset
> from zookeeper.
>
> According to https://kafka.apache.org/08/configuration.html for "
> https://kafka.apache.org/08/configuration.html"
>
> > What to do when there is no initial offset in Zookeeper or if an offset
> is out of range:
> ..
> >* anything else: throw exception to the consumer
>
>
> But it looks like the exception is always thrown, not only when there is
> no initial offset found in Zookeper. It;s being validated at startup...
> Is there a workaround to fail only if no offset is found in zk?
>
> Regards,
>
> Martin

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB