[jira] [Created] (STORM-1747) storm-kafka-client KafkaSpoutRetryExponentialBackoff throws exception

["Jifeng Yin (JIRA)" <ji...@apache.org>]

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)