[ https://issues.apache.org/jira/browse/KAFKA-619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
John Fung closed KAFKA-619. --------------------------- > Regression : System Test 900x (Migration Tool) - > java.lang.ClassCastException: kafka.message.Message cannot be cast to [B > ------------------------------------------------------------------------------------------------------------------------- > > Key: KAFKA-619 > URL: https://issues.apache.org/jira/browse/KAFKA-619 > Project: Kafka > Issue Type: Bug > Reporter: John Fung > > This error is happening in : testcase_900x (migration tool test group). The > issue is that no data is received by ConsoleConsumer. All Migration Tool > log4j messages are showing the following error. > . . . > [2012-11-16 08:28:55,361] INFO FetchRunnable-1 start fetching topic: test_1 > part: 3 offset: 0 from 127.0.0.1:9093 (kafka.consumer.FetcherRunnable) > [2012-11-16 08:28:55,361] INFO FetchRunnable-0 start fetching topic: test_1 > part: 3 offset: 0 from 127.0.0.1:9092 (kafka.consumer.FetcherRunnable) > [2012-11-16 08:28:55,361] INFO FetchRunnable-2 start fetching topic: test_1 > part: 0 offset: 0 from 127.0.0.1:9091 (kafka.consumer.FetcherRunnable) > Migration thread failure due to java.lang.ClassCastException: > kafka.message.Message cannot be cast to [B > java.lang.ClassCastException: kafka.message.Message cannot be cast to [B > at kafka.serializer.DefaultEncoder.toBytes(Encoder.scala:36) > at > kafka.producer.async.DefaultEventHandler$$anonfun$serialize$1.apply(DefaultEventHandler.scala:111) > at > kafka.producer.async.DefaultEventHandler$$anonfun$serialize$1.apply(DefaultEventHandler.scala:106) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:206) > at > scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:34) > at > scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:32) > at > scala.collection.TraversableLike$class.map(TraversableLike.scala:206) > at scala.collection.mutable.WrappedArray.map(WrappedArray.scala:32) > at > kafka.producer.async.DefaultEventHandler.serialize(DefaultEventHandler.scala:106) > at > kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:47) > at kafka.producer.Producer.send(Producer.scala:75) > at kafka.javaapi.producer.Producer.send(Producer.scala:32) > at > kafka.tools.KafkaMigrationTool$MigrationThread.run(KafkaMigrationTool.java:287) > [2012-11-16 08:30:04,854] INFO > test-consumer-group_jfung-ld-1353083318174-2b62271b begin rebalancing > consumer test-consumer-group_jfung-ld-1353083318174-2b62271b try #0 > (kafka.consumer.ZookeeperConsumerConnector) > [2012-11-16 08:30:04,858] INFO Constructing topic count for > test-consumer-group_jfung-ld-1353083318174-2b62271b from *2*.* using > \*(\p{Digit}+)\*(.*) as pattern. (kafka.consumer.TopicCount$) > . . . -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira