Jifeng Yin created STORM-1747:
---------------------------------
Summary: storm-kafka-client KafkaSpoutRetryExponentialBackoff
throws exception
Key: STORM-1747
URL: https://issues.apache.org/jira/browse/STORM-1747
Project: Apache Storm
Issue Type: Bug
Reporter: Jifeng Yin
{code}
java.lang.ClassCastException: org.apache.kafka.common.TopicPartition cannot be
cast to java.lang.Comparable
at java.util.TreeMap.compare(TreeMap.java:1188) ~[?:1.7.0_80]
at java.util.TreeMap.put(TreeMap.java:531) ~[?:1.7.0_80]
at java.util.TreeSet.add(TreeSet.java:255) ~[?:1.7.0_80]
at
org.apache.storm.kafka.spout.KafkaSpoutRetryExponentialBackoff.retriableTopicPartitions(KafkaSpoutRetryExponentialBackoff.java:170)
~[storm-kafka-client-1.0.0.jar:1.0.0]
at
org.apache.storm.kafka.spout.KafkaSpout.doSeekRetriableTopicPartitions(KafkaSpout.java:245)
~[storm-kafka-client-1.0.0.jar:1.0.0]
at
org.apache.storm.kafka.spout.KafkaSpout.pollKafkaBroker(KafkaSpout.java:236)
~[storm-kafka-client-1.0.0.jar:1.0.0]
at
org.apache.storm.kafka.spout.KafkaSpout.nextTuple(KafkaSpout.java:202)
~[storm-kafka-client-1.0.0.jar:1.0.0]
at
org.apache.storm.daemon.executor$fn__7877$fn__7892$fn__7923.invoke(executor.clj:647)
~[storm-core-1.0.0.jar:1.0.0]
at org.apache.storm.util$async_loop$fn__625.invoke(util.clj:484)
[storm-core-1.0.0.jar:1.0.0]
at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
at java.lang.Thread.run(Thread.java:745) [?:1.7.0_80]
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
