gistfile1.txt

ruby message: "\n\x05rspec\x10\x03\x18\xA9F" String (12 bytes)
DATA: #<Java::KafkaProducer::KeyedMessage:0x52cc5f53>
e: java.lang.ClassCastException: [B cannot be cast to java.lang.String
kafka.serializer.StringEncoder.toBytes(Encoder.scala:46)
kafka.serializer.StringEncoder.toBytes(kafka/serializer/Encoder.scala:46)
kafka.producer.async.DefaultEventHandler$$anonfun$serialize$1.apply(DefaultEventHandler.scala:130)
kafka.producer.async.DefaultEventHandler$$anonfun$serialize$1.apply(kafka/producer/async/DefaultEventHandler.scala:130)
kafka.producer.async.DefaultEventHandler$$anonfun$serialize$1.apply(DefaultEventHandler.scala:125)
kafka.producer.async.DefaultEventHandler$$anonfun$serialize$1.apply(kafka/producer/async/DefaultEventHandler.scala:125)
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
scala.collection.TraversableLike$$anonfun$map$1.apply(scala/collection/TraversableLike.scala:244)
scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
scala.collection.TraversableLike$$anonfun$map$1.apply(scala/collection/TraversableLike.scala:244)
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
scala.collection.IndexedSeqOptimized$class.foreach(scala/collection/IndexedSeqOptimized.scala:33)
scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:34)
scala.collection.mutable.WrappedArray.foreach(scala/collection/mutable/WrappedArray.scala:34)
scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
scala.collection.TraversableLike$class.map(scala/collection/TraversableLike.scala:244)
scala.collection.AbstractTraversable.map(Traversable.scala:105)
scala.collection.AbstractTraversable.map(scala/collection/Traversable.scala:105)
kafka.producer.async.DefaultEventHandler.serialize(DefaultEventHandler.scala:125)
kafka.producer.async.DefaultEventHandler.serialize(kafka/producer/async/DefaultEventHandler.scala:125)
kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:52)
kafka.producer.async.DefaultEventHandler.handle(kafka/producer/async/DefaultEventHandler.scala:52)
kafka.producer.Producer.send(Producer.scala:76)
kafka.producer.Producer.send(kafka/producer/Producer.scala:76)
kafka.javaapi.producer.Producer.send(Producer.scala:33)
kafka.javaapi.producer.Producer.send(kafka/javaapi/producer/Producer.scala:33)
java.lang.reflect.Method.invoke(java/lang/reflect/Method.java:483)
RUBY.push_single(/usr/home/tyler/source/github/ruby/Hermann/lib/hermann/provider/java_producer.rb:53)
org.jruby.RubyProc.call(org/jruby/RubyProc.java:271)
RUBY.execute(/home/tyler/.rvm/gems/jruby-1.7.15@rubygems/gems/concurrent-ruby-0.7.0-java/lib/concurrent/executor/safe_task_executor.rb:24)
org.jruby.ext.thread.Mutex.synchronize(org/jruby/ext/thread/Mutex.java:149)
RUBY.execute(/home/tyler/.rvm/gems/jruby-1.7.15@rubygems/gems/concurrent-ruby-0.7.0-java/lib/concurrent/executor/safe_task_executor.rb:19)
RUBY.realize(/home/tyler/.rvm/gems/jruby-1.7.15@rubygems/gems/concurrent-ruby-0.7.0-java/lib/concurrent/promise.rb:147)
RUBY.post(/home/tyler/.rvm/gems/jruby-1.7.15@rubygems/gems/concurrent-ruby-0.7.0-java/lib/concurrent/executor/executor.rb:0)
org.jruby.gen.InterfaceImpl1568332424.run(org/jruby/gen/InterfaceImpl1568332424.gen:13)
java.util.concurrent.Executors$RunnableAdapter.call(java/util/concurrent/Executors.java:511)
java.util.concurrent.FutureTask.run(java/util/concurrent/FutureTask.java:266)
java.util.concurrent.ThreadPoolExecutor.runWorker(java/util/concurrent/ThreadPoolExecutor.java:1142)
java.util.concurrent.ThreadPoolExecutor$Worker.run(java/util/concurrent/ThreadPoolExecutor.java:617)
java.lang.Thread.run(java/lang/Thread.java:745)