John Fung created KAFKA-619: ------------------------------- Summary: System Test Regression 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
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) -- 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