You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Manjeer Srujan. Y (JIRA)" <ji...@apache.org> on 2017/02/28 10:38:45 UTC
[jira] [Created] (KAFKA-4812) We are facing the same issue as
SAMZA-590
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)