[
https://issues.apache.org/jira/browse/KAFKA-619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Fung updated KAFKA-619:
----------------------------
Description:
. . .
[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$)
. . .
was:
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)
> 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
>
> . . .
> [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
