Martin, "other" is not a valid value for auto.offset.reset. This is explained in the exception itself "kafka.common.InvalidConfigException: Wrong value other of auto.offset.reset in ConsumerConfig; Valid values are smallest and largest".
Thanks, Jun On Mon, Jul 1, 2013 at 9:28 PM, Martin Eigenbrodt < [email protected]> wrote: > > On 01.07.2013, at 17:45, Jun Rao <[email protected]> wrote: > > Not sure that I fully understand your problem. Could you attach the > > exception that you saw? > > Here is what I do and get: > > I use the High Level Consumer and configured it with > > auto.offset.reset = other > > I get > > kafka.common.InvalidConfigException: Wrong value other of > auto.offset.reset in ConsumerConfig; Valid values are smallest and largest > at kafka.consumer.ConsumerConfig$.validateAutoOffsetReset(Unknown > Source) ~[kafka-0.8.0-SNAPSHOT.jar:0.8.0-SNAPSHOT+37] > at kafka.consumer.ConsumerConfig$.validate(Unknown Source) > ~[kafka-0.8.0-SNAPSHOT.jar:0.8.0-SNAPSHOT+37] > at kafka.consumer.ConsumerConfig.<init>(Unknown Source) > ~[kafka-0.8.0-SNAPSHOT.jar:0.8.0-SNAPSHOT+37] > at kafka.consumer.ConsumerConfig.<init>(Unknown Source) > ~[kafka-0.8.0-SNAPSHOT.jar:0.8.0-SNAPSHOT+37] > > as soon as I try to > > val consumerConfig = new ConsumerConfig(props); > > > > What I expected: > > - No Exception on initialization > - No Exception if the consumer can connect to Zookeeper and fetch a valid > offset > - An Exception if it can not reach Zookeeper or it does not contain a > valid offset for the given consumer group > > > Regards, > > Martin > > > > > 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 > >
