Tim - Actually I was looking at the wrong commit (0.8.1 has 0.8.1.1 commits in it). The 0.8.1.0 tag has deleteTopicManager.shutdown() on KafkaController.scala:340. Not sure how deleteTopicManager can skip initialization.
On Wed, Apr 2, 2014 at 4:00 PM, Clark Breyman <cl...@breyman.com> wrote: > Hey Tim. Small world :). > > Kafka 0.8.1_2.10 > > > > > On Wed, Apr 2, 2014 at 3:54 PM, Timothy Chen <tnac...@gmail.com> wrote: > >> Hi Clark, >> >> What version of Kafka are you running this from? >> >> Thanks, >> >> Tim >> >> >> On Wed, Apr 2, 2014 at 3:49 PM, Clark Breyman <cl...@breyman.com> wrote: >> >> > I'm seeing a lot of this in my logs on a non-controller broker: >> > >> > 2014-04-02 15:42:23,078] ERROR Error handling event ZkEvent[New session >> > event sent to >> > kafka.controller.KafkaController$SessionExpirationListener@204a18ac] >> > (org.I0Itec.zkclient.ZkEventThread) >> > java.lang.NullPointerException >> > at >> > >> > >> kafka.controller.KafkaController$anonfun$onControllerResignation$1.apply$mcV$sp(KafkaController.scala:340) >> > at >> > >> > >> kafka.controller.KafkaController$anonfun$onControllerResignation$1.apply(KafkaController.scala:337) >> > at >> > >> > >> kafka.controller.KafkaController$anonfun$onControllerResignation$1.apply(KafkaController.scala:337) >> > at kafka.utils.Utils$.inLock(Utils.scala:538) >> > at >> > >> > >> kafka.controller.KafkaController.onControllerResignation(KafkaController.scala:337) >> > at >> > >> > >> kafka.controller.KafkaController$SessionExpirationListener$anonfun$handleNewSession$1.apply$mcZ$sp(KafkaController.scala:1068) >> > at >> > >> > >> kafka.controller.KafkaController$SessionExpirationListener$anonfun$handleNewSession$1.apply(KafkaController.scala:1067) >> > at >> > >> > >> kafka.controller.KafkaController$SessionExpirationListener$anonfun$handleNewSession$1.apply(KafkaController.scala:1067) >> > at kafka.utils.Utils$.inLock(Utils.scala:538) >> > at >> > >> > >> kafka.controller.KafkaController$SessionExpirationListener.handleNewSession(KafkaController.scala:1067) >> > at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472) >> > at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71) >> > >> > >> > Is it associated with KAFKA-1310 or is it something else? >> > >> > It seems to be coming at the beginning of onControllerResignation, so >> non >> > of the other shutdowns get triggered. >> > >> > >
