kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Clark Breyman <cl...@breyman.com>
Subject Re: NullPointerException in broker on notification of ZK session end
Date Wed, 02 Apr 2014 23:45:12 GMT
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 <clark@breyman.com> wrote:

> Hey Tim. Small world :).
>
> Kafka 0.8.1_2.10
>
>
>
>
> On Wed, Apr 2, 2014 at 3:54 PM, Timothy Chen <tnachen@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 <clark@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.
>> >
>>
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message