You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Jun Rao (JIRA)" <ji...@apache.org> on 2012/08/15 18:54:38 UTC
[jira] [Created] (KAFKA-464) KafkaController NPE in
SessionExpireListener
Jun Rao created KAFKA-464:
-----------------------------
Summary: KafkaController NPE in SessionExpireListener
Key: KAFKA-464
URL: https://issues.apache.org/jira/browse/KAFKA-464
Project: Kafka
Issue Type: Bug
Components: core
Reporter: Jun Rao
Fix For: 0.8
Sometime see the following in LogRecoverTest.
[2012-08-15 09:06:01,845] ERROR Error handling event ZkEvent[New session event sent to kafka.server.KafkaController$SessionExpireListener@e8ae59a] (org.I0Itec.zkclient.ZkEventThread)
java.lang.NullPointerException
at kafka.server.KafkaController$SessionExpireListener.handleNewSession(KafkaController.scala:284)
at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (KAFKA-464) KafkaController NPE in
SessionExpireListener
Posted by "Yang Ye (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yang Ye updated KAFKA-464:
--------------------------
Attachment: kafka_464_v4.diff
> KafkaController NPE in SessionExpireListener
> --------------------------------------------
>
> Key: KAFKA-464
> URL: https://issues.apache.org/jira/browse/KAFKA-464
> Project: Kafka
> Issue Type: Bug
> Components: core
> Reporter: Jun Rao
> Labels: bugs
> Fix For: 0.8
>
> Attachments: kafka_464.diff, kafka_464_v2.diff, kafka_464_v3.diff, kafka_464_v4.diff
>
> Original Estimate: 48h
> Remaining Estimate: 48h
>
> Sometime see the following in LogRecoverTest.
> [2012-08-15 09:06:01,845] ERROR Error handling event ZkEvent[New session event sent to kafka.server.KafkaController$SessionExpireListener@e8ae59a] (org.I0Itec.zkclient.ZkEventThread)
> java.lang.NullPointerException
> at kafka.server.KafkaController$SessionExpireListener.handleNewSession(KafkaController.scala:284)
> at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
> at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (KAFKA-464) KafkaController NPE in
SessionExpireListener
Posted by "Jun Rao (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13436099#comment-13436099 ]
Jun Rao commented on KAFKA-464:
-------------------------------
Also, instead of testing controllerChannelManager is null, can we use isActive()?
> KafkaController NPE in SessionExpireListener
> --------------------------------------------
>
> Key: KAFKA-464
> URL: https://issues.apache.org/jira/browse/KAFKA-464
> Project: Kafka
> Issue Type: Bug
> Components: core
> Reporter: Jun Rao
> Labels: bugs
> Fix For: 0.8
>
> Attachments: kafka_464.diff
>
> Original Estimate: 48h
> Remaining Estimate: 48h
>
> Sometime see the following in LogRecoverTest.
> [2012-08-15 09:06:01,845] ERROR Error handling event ZkEvent[New session event sent to kafka.server.KafkaController$SessionExpireListener@e8ae59a] (org.I0Itec.zkclient.ZkEventThread)
> java.lang.NullPointerException
> at kafka.server.KafkaController$SessionExpireListener.handleNewSession(KafkaController.scala:284)
> at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
> at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Closed] (KAFKA-464) KafkaController NPE in
SessionExpireListener
Posted by "Jun Rao (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jun Rao closed KAFKA-464.
-------------------------
> KafkaController NPE in SessionExpireListener
> --------------------------------------------
>
> Key: KAFKA-464
> URL: https://issues.apache.org/jira/browse/KAFKA-464
> Project: Kafka
> Issue Type: Bug
> Components: core
> Reporter: Jun Rao
> Assignee: Yang Ye
> Labels: bugs
> Fix For: 0.8
>
> Attachments: kafka_464.diff, kafka_464_v2.diff, kafka_464_v3.diff, kafka_464_v4.diff, kafka_464_v5.diff
>
> Original Estimate: 48h
> Remaining Estimate: 48h
>
> Sometime see the following in LogRecoverTest.
> [2012-08-15 09:06:01,845] ERROR Error handling event ZkEvent[New session event sent to kafka.server.KafkaController$SessionExpireListener@e8ae59a] (org.I0Itec.zkclient.ZkEventThread)
> java.lang.NullPointerException
> at kafka.server.KafkaController$SessionExpireListener.handleNewSession(KafkaController.scala:284)
> at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
> at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (KAFKA-464) KafkaController NPE in
SessionExpireListener
Posted by "Jun Rao (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13436098#comment-13436098 ]
Jun Rao commented on KAFKA-464:
-------------------------------
Thanks for the patch.
I think you always need to call controllerRegisterOrFailover when handling a new session, whether controllerChannelManager is null or not.
> KafkaController NPE in SessionExpireListener
> --------------------------------------------
>
> Key: KAFKA-464
> URL: https://issues.apache.org/jira/browse/KAFKA-464
> Project: Kafka
> Issue Type: Bug
> Components: core
> Reporter: Jun Rao
> Labels: bugs
> Fix For: 0.8
>
> Attachments: kafka_464.diff
>
> Original Estimate: 48h
> Remaining Estimate: 48h
>
> Sometime see the following in LogRecoverTest.
> [2012-08-15 09:06:01,845] ERROR Error handling event ZkEvent[New session event sent to kafka.server.KafkaController$SessionExpireListener@e8ae59a] (org.I0Itec.zkclient.ZkEventThread)
> java.lang.NullPointerException
> at kafka.server.KafkaController$SessionExpireListener.handleNewSession(KafkaController.scala:284)
> at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
> at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (KAFKA-464) KafkaController NPE in
SessionExpireListener
Posted by "Yang Ye (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yang Ye updated KAFKA-464:
--------------------------
Attachment: kafka_464_v3.diff
Sorry for missing it...
> KafkaController NPE in SessionExpireListener
> --------------------------------------------
>
> Key: KAFKA-464
> URL: https://issues.apache.org/jira/browse/KAFKA-464
> Project: Kafka
> Issue Type: Bug
> Components: core
> Reporter: Jun Rao
> Labels: bugs
> Fix For: 0.8
>
> Attachments: kafka_464.diff, kafka_464_v2.diff, kafka_464_v3.diff
>
> Original Estimate: 48h
> Remaining Estimate: 48h
>
> Sometime see the following in LogRecoverTest.
> [2012-08-15 09:06:01,845] ERROR Error handling event ZkEvent[New session event sent to kafka.server.KafkaController$SessionExpireListener@e8ae59a] (org.I0Itec.zkclient.ZkEventThread)
> java.lang.NullPointerException
> at kafka.server.KafkaController$SessionExpireListener.handleNewSession(KafkaController.scala:284)
> at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
> at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Resolved] (KAFKA-464) KafkaController NPE in
SessionExpireListener
Posted by "Jun Rao (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jun Rao resolved KAFKA-464.
---------------------------
Resolution: Fixed
Assignee: Yang Ye
Thanks for patch v5. Committed to 0.8
> KafkaController NPE in SessionExpireListener
> --------------------------------------------
>
> Key: KAFKA-464
> URL: https://issues.apache.org/jira/browse/KAFKA-464
> Project: Kafka
> Issue Type: Bug
> Components: core
> Reporter: Jun Rao
> Assignee: Yang Ye
> Labels: bugs
> Fix For: 0.8
>
> Attachments: kafka_464.diff, kafka_464_v2.diff, kafka_464_v3.diff, kafka_464_v4.diff, kafka_464_v5.diff
>
> Original Estimate: 48h
> Remaining Estimate: 48h
>
> Sometime see the following in LogRecoverTest.
> [2012-08-15 09:06:01,845] ERROR Error handling event ZkEvent[New session event sent to kafka.server.KafkaController$SessionExpireListener@e8ae59a] (org.I0Itec.zkclient.ZkEventThread)
> java.lang.NullPointerException
> at kafka.server.KafkaController$SessionExpireListener.handleNewSession(KafkaController.scala:284)
> at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
> at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (KAFKA-464) KafkaController NPE in
SessionExpireListener
Posted by "Neha Narkhede (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13437090#comment-13437090 ]
Neha Narkhede commented on KAFKA-464:
-------------------------------------
Minor comments -
1.1 Rename shutDown to shutdown()
1.2 Rename isLeaderController to isController or isCurrentController
> KafkaController NPE in SessionExpireListener
> --------------------------------------------
>
> Key: KAFKA-464
> URL: https://issues.apache.org/jira/browse/KAFKA-464
> Project: Kafka
> Issue Type: Bug
> Components: core
> Reporter: Jun Rao
> Labels: bugs
> Fix For: 0.8
>
> Attachments: kafka_464.diff, kafka_464_v2.diff, kafka_464_v3.diff, kafka_464_v4.diff
>
> Original Estimate: 48h
> Remaining Estimate: 48h
>
> Sometime see the following in LogRecoverTest.
> [2012-08-15 09:06:01,845] ERROR Error handling event ZkEvent[New session event sent to kafka.server.KafkaController$SessionExpireListener@e8ae59a] (org.I0Itec.zkclient.ZkEventThread)
> java.lang.NullPointerException
> at kafka.server.KafkaController$SessionExpireListener.handleNewSession(KafkaController.scala:284)
> at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
> at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (KAFKA-464) KafkaController NPE in
SessionExpireListener
Posted by "Yang Ye (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yang Ye updated KAFKA-464:
--------------------------
Attachment: kafka_464.diff
Fixed it
> KafkaController NPE in SessionExpireListener
> --------------------------------------------
>
> Key: KAFKA-464
> URL: https://issues.apache.org/jira/browse/KAFKA-464
> Project: Kafka
> Issue Type: Bug
> Components: core
> Reporter: Jun Rao
> Labels: bugs
> Fix For: 0.8
>
> Attachments: kafka_464.diff
>
> Original Estimate: 48h
> Remaining Estimate: 48h
>
> Sometime see the following in LogRecoverTest.
> [2012-08-15 09:06:01,845] ERROR Error handling event ZkEvent[New session event sent to kafka.server.KafkaController$SessionExpireListener@e8ae59a] (org.I0Itec.zkclient.ZkEventThread)
> java.lang.NullPointerException
> at kafka.server.KafkaController$SessionExpireListener.handleNewSession(KafkaController.scala:284)
> at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
> at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (KAFKA-464) KafkaController NPE in
SessionExpireListener
Posted by "Yang Ye (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yang Ye updated KAFKA-464:
--------------------------
Attachment: kafka_464_v5.diff
So I find a few other places in the code using "startUp" or "shutDown", let me fix them all together.
> KafkaController NPE in SessionExpireListener
> --------------------------------------------
>
> Key: KAFKA-464
> URL: https://issues.apache.org/jira/browse/KAFKA-464
> Project: Kafka
> Issue Type: Bug
> Components: core
> Reporter: Jun Rao
> Labels: bugs
> Fix For: 0.8
>
> Attachments: kafka_464.diff, kafka_464_v2.diff, kafka_464_v3.diff, kafka_464_v4.diff, kafka_464_v5.diff
>
> Original Estimate: 48h
> Remaining Estimate: 48h
>
> Sometime see the following in LogRecoverTest.
> [2012-08-15 09:06:01,845] ERROR Error handling event ZkEvent[New session event sent to kafka.server.KafkaController$SessionExpireListener@e8ae59a] (org.I0Itec.zkclient.ZkEventThread)
> java.lang.NullPointerException
> at kafka.server.KafkaController$SessionExpireListener.handleNewSession(KafkaController.scala:284)
> at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
> at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (KAFKA-464) KafkaController NPE in
SessionExpireListener
Posted by "Yang Ye (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13437088#comment-13437088 ]
Yang Ye commented on KAFKA-464:
-------------------------------
V4 fixes as suggested
> KafkaController NPE in SessionExpireListener
> --------------------------------------------
>
> Key: KAFKA-464
> URL: https://issues.apache.org/jira/browse/KAFKA-464
> Project: Kafka
> Issue Type: Bug
> Components: core
> Reporter: Jun Rao
> Labels: bugs
> Fix For: 0.8
>
> Attachments: kafka_464.diff, kafka_464_v2.diff, kafka_464_v3.diff, kafka_464_v4.diff
>
> Original Estimate: 48h
> Remaining Estimate: 48h
>
> Sometime see the following in LogRecoverTest.
> [2012-08-15 09:06:01,845] ERROR Error handling event ZkEvent[New session event sent to kafka.server.KafkaController$SessionExpireListener@e8ae59a] (org.I0Itec.zkclient.ZkEventThread)
> java.lang.NullPointerException
> at kafka.server.KafkaController$SessionExpireListener.handleNewSession(KafkaController.scala:284)
> at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
> at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (KAFKA-464) KafkaController NPE in
SessionExpireListener
Posted by "Jun Rao (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13436553#comment-13436553 ]
Jun Rao commented on KAFKA-464:
-------------------------------
Well, unfortunately, v2 doesn't address the original problem that controllerChannelManager can be null when calling controllerChannelManager.shutdown in handleNewSession().
> KafkaController NPE in SessionExpireListener
> --------------------------------------------
>
> Key: KAFKA-464
> URL: https://issues.apache.org/jira/browse/KAFKA-464
> Project: Kafka
> Issue Type: Bug
> Components: core
> Reporter: Jun Rao
> Labels: bugs
> Fix For: 0.8
>
> Attachments: kafka_464.diff, kafka_464_v2.diff
>
> Original Estimate: 48h
> Remaining Estimate: 48h
>
> Sometime see the following in LogRecoverTest.
> [2012-08-15 09:06:01,845] ERROR Error handling event ZkEvent[New session event sent to kafka.server.KafkaController$SessionExpireListener@e8ae59a] (org.I0Itec.zkclient.ZkEventThread)
> java.lang.NullPointerException
> at kafka.server.KafkaController$SessionExpireListener.handleNewSession(KafkaController.scala:284)
> at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
> at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (KAFKA-464) KafkaController NPE in
SessionExpireListener
Posted by "Yang Ye (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yang Ye updated KAFKA-464:
--------------------------
Attachment: kafka_464_v2.diff
Added a new flag of isRunning in controller and always call controllerRegisterOrFailOver() on session expiration
> KafkaController NPE in SessionExpireListener
> --------------------------------------------
>
> Key: KAFKA-464
> URL: https://issues.apache.org/jira/browse/KAFKA-464
> Project: Kafka
> Issue Type: Bug
> Components: core
> Reporter: Jun Rao
> Labels: bugs
> Fix For: 0.8
>
> Attachments: kafka_464.diff, kafka_464_v2.diff
>
> Original Estimate: 48h
> Remaining Estimate: 48h
>
> Sometime see the following in LogRecoverTest.
> [2012-08-15 09:06:01,845] ERROR Error handling event ZkEvent[New session event sent to kafka.server.KafkaController$SessionExpireListener@e8ae59a] (org.I0Itec.zkclient.ZkEventThread)
> java.lang.NullPointerException
> at kafka.server.KafkaController$SessionExpireListener.handleNewSession(KafkaController.scala:284)
> at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
> at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (KAFKA-464) KafkaController NPE in
SessionExpireListener
Posted by "Jun Rao (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13436793#comment-13436793 ]
Jun Rao commented on KAFKA-464:
-------------------------------
A couple of more comments:
1. The following check in handleNewSession() should probably be done inside controllerRegisterOrFailover() since other callers of controllerRegisterOrFailover() should check isRunning too.
if(isRunning)
controllerRegisterOrFailover()
2. This is not really related to this jira, but it's in KafkaController. So, maybe we can fix it in this jira too. It seems that we can simplify the following code in controllerRegisterOrFailover() using filter() on a map.
// If there are some partition with leader not initialized, init the leader for them
val partitionReplicaAssignment = allPartitionReplicaAssignment.clone()
for((topicPartition, replicas) <- partitionReplicaAssignment){
if (allLeaders.contains(topicPartition)){
partitionReplicaAssignment.remove(topicPartition)
}
}
> KafkaController NPE in SessionExpireListener
> --------------------------------------------
>
> Key: KAFKA-464
> URL: https://issues.apache.org/jira/browse/KAFKA-464
> Project: Kafka
> Issue Type: Bug
> Components: core
> Reporter: Jun Rao
> Labels: bugs
> Fix For: 0.8
>
> Attachments: kafka_464.diff, kafka_464_v2.diff, kafka_464_v3.diff
>
> Original Estimate: 48h
> Remaining Estimate: 48h
>
> Sometime see the following in LogRecoverTest.
> [2012-08-15 09:06:01,845] ERROR Error handling event ZkEvent[New session event sent to kafka.server.KafkaController$SessionExpireListener@e8ae59a] (org.I0Itec.zkclient.ZkEventThread)
> java.lang.NullPointerException
> at kafka.server.KafkaController$SessionExpireListener.handleNewSession(KafkaController.scala:284)
> at org.I0Itec.zkclient.ZkClient$4.run(ZkClient.java:472)
> at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:71)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira