[jira] [Created] (KAFKA-4812) We are facing the same issue as SAMZA-590

[Manjeer Srujan. Y (JIRA)]

Manjeer Srujan. Y created KAFKA-4812:
----------------------------------------

             Summary: We are facing the same issue as SAMZA-590
                 Key: KAFKA-4812
                 URL: https://issues.apache.org/jira/browse/KAFKA-4812
             Project: Kafka
          Issue Type: Bug
            Reporter: Manjeer Srujan. Y
            Priority: Critical


Dead Kafka broker ignores new leader.

We are facing the same issue as samza issue below. But, we couldn't find any 
fix for this in kafka. Pasted the log below for reference.

The kafka client that we are using is below.

group: 'org.apache.kafka', name: 'kafka_2.10', version: '0.8.2.1'

https://issues.apache.org/jira/browse/SAMZA-590

2017-02-28 09:50:53.189 29708 [Thread-11-vendor-index-spout-executor[35 35]] 
ERROR org.apache.storm.daemon.executor -  - java.lang.RuntimeException: 
java.nio.channels.ClosedChannelException
        at org.apache.storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:103)
        at 
org.apache.storm.kafka.ZkCoordinator.getMyManagedPartitions(ZkCoordinator.java:69)
        at org.apache.storm.kafka.KafkaSpout.nextTuple(KafkaSpout.java:129)
        at 
org.apache.storm.daemon.executor$fn__7990$fn__8005$fn__8036.invoke(executor.clj:648)
        at org.apache.storm.util$async_loop$fn__624.invoke(util.clj:484)
        at clojure.lang.AFn.run(AFn.java:22)
        at java.lang.Thread.run(Thread.java:745)
Caused by: java.nio.channels.ClosedChannelException
        at kafka.network.BlockingChannel.send(BlockingChannel.scala:100)
        at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:78)
        at 
kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:68)
        at 
kafka.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:127)
        at 
kafka.javaapi.consumer.SimpleConsumer.getOffsetsBefore(SimpleConsumer.scala:79)
        at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:75)
        at org.apache.storm.kafka.KafkaUtils.getOffset(KafkaUtils.java:65)
        at 
org.apache.storm.kafka.PartitionManager.<init>(PartitionManager.java:94)
        at org.apache.storm.kafka.ZkCoordinator.refresh(ZkCoordinator.java:98)
        ... 6 more



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)