This seems to be a bug. We should send the message string, instead the Message object in DataGenerator. Could you file a jira?
Thanks, Jun On Thu, May 30, 2013 at 1:47 PM, Andrew Milkowski <[email protected]>wrote: > Hi, > > Working of git master codebase > > and following instructions at > > https://github.com/apache/kafka/blob/trunk/contrib/hadoop-consumer/README > > https://github.com/apache/kafka > > when running > > ./run-class.sh kafka.etl.impl.DataGenerator test/test.properties > > an exception is thrown > > Exception in thread "main" java.lang.ClassCastException: > kafka.message.Message cannot be cast to [B > at kafka.serializer.DefaultEncoder.toBytes(Encoder.scala:34) > at > > kafka.producer.async.DefaultEventHandler$$anonfun$serialize$1.apply(DefaultEventHandler.scala:129) > at > > kafka.producer.async.DefaultEventHandler$$anonfun$serialize$1.apply(DefaultEventHandler.scala:124) > at > > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) > at > > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:233) > at scala.collection.Iterator$class.foreach(Iterator.scala:772) > at > > scala.collection.JavaConversions$JIteratorWrapper.foreach(JavaConversions.scala:573) > at scala.collection.IterableLike$class.foreach(IterableLike.scala:73) > at > > scala.collection.JavaConversions$JListWrapper.foreach(JavaConversions.scala:615) > at scala.collection.TraversableLike$class.map(TraversableLike.scala:233) > at > > scala.collection.JavaConversions$JListWrapper.map(JavaConversions.scala:615) > at > > kafka.producer.async.DefaultEventHandler.serialize(DefaultEventHandler.scala:124) > at > > kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:54) > at kafka.producer.Producer.send(Producer.scala:74) > at kafka.javaapi.producer.Producer.send(Producer.scala:41) > > please advice, thank you! >
