Skip to content
This repository has been archived by the owner on Nov 20, 2019. It is now read-only.

Tighten up connection refused errors around lack of leaders #32

Open
rtyler opened this issue Aug 15, 2015 · 0 comments
Open

Tighten up connection refused errors around lack of leaders #32

rtyler opened this issue Aug 15, 2015 · 0 comments

Comments

@rtyler
Copy link
Member

rtyler commented Aug 15, 2015

01:07:32.975 [Thread-1] ERROR c.g.lookout.verspaetung.KafkaPoller - Failed to fetch latest for REDACTED:2
kafka.common.NotLeaderForPartitionException: null
        at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[na:1.7.0_75]
        at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) ~[na:1.7.0_75]
        at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ~[na:1.7.0_75]
        at java.lang.reflect.Constructor.newInstance(Constructor.java:526) ~[na:1.7.0_75]
        at java.lang.Class.newInstance(Class.java:379) ~[na:1.7.0_75]
        at kafka.common.ErrorMapping$.exceptionFor(ErrorMapping.scala:73) ~[verspaetung-0.3.0-all.jar:na]
        at kafka.consumer.SimpleConsumer.earliestOrLatestOffset(SimpleConsumer.scala:160) ~[verspaetung-0.3.0-all.jar:na]
        at sun.reflect.GeneratedMethodAccessor18.invoke(Unknown Source) ~[na:na]
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.7.0_75]
        at java.lang.reflect.Method.invoke(Method.java:606) ~[na:1.7.0_75]
        at org.codehaus.groovy.runtime.callsite.PojoMetaMethodSite$PojoCachedMethodSiteNoUnwrap.invoke(PojoMetaMethodSite.java:210) ~[verspaetung-0.3.0-all.jar:na]
        at org.codehaus.groovy.runtime.callsite.PojoMetaMethodSite.call(PojoMetaMethodSite.java:53) [verspaetung-0.3.0-all.jar:na]
        at org.codehaus.groovy.runtime.callsite.AbstractCallSite.call(AbstractCallSite.java:138) [verspaetung-0.3.0-all.jar:na]
        at com.github.lookout.verspaetung.KafkaPoller.latestFromLeader(KafkaPoller.groovy:128) [verspaetung-0.3.0-all.jar:na]

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Development

No branches or pull requests

1 participant