Return-Path: X-Original-To: apmail-camel-users-archive@www.apache.org Delivered-To: apmail-camel-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 20C5A17FD5 for ; Sun, 14 Jun 2015 20:40:43 +0000 (UTC) Received: (qmail 63185 invoked by uid 500); 14 Jun 2015 20:40:42 -0000 Delivered-To: apmail-camel-users-archive@camel.apache.org Received: (qmail 63136 invoked by uid 500); 14 Jun 2015 20:40:42 -0000 Mailing-List: contact users-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@camel.apache.org Delivered-To: mailing list users@camel.apache.org Received: (qmail 63124 invoked by uid 99); 14 Jun 2015 20:40:42 -0000 Received: from Unknown (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 14 Jun 2015 20:40:42 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id EEBE51A55E8 for ; Sun, 14 Jun 2015 20:40:41 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.041 X-Spam-Level: ** X-Spam-Status: No, score=2.041 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, FREEMAIL_ENVFROM_END_DIGIT=0.25, HTML_MESSAGE=3, RCVD_IN_MSPIKE_H2=-1.108, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-eu-west.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id oitlgklY2gvq for ; Sun, 14 Jun 2015 20:40:39 +0000 (UTC) Received: from mail-oi0-f44.google.com (mail-oi0-f44.google.com [209.85.218.44]) by mx1-eu-west.apache.org (ASF Mail Server at mx1-eu-west.apache.org) with ESMTPS id 48FCC24D0F for ; Sun, 14 Jun 2015 20:40:38 +0000 (UTC) Received: by oial131 with SMTP id l131so14256341oia.3 for ; Sun, 14 Jun 2015 13:40:31 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:from:date:message-id:subject:to:content-type; bh=kMrn77icz7dJJtXKY5mJKDBTrmeRV7uXHIbrbLvIpcE=; b=EZi7/bDP/KhNLNgEzqqUy4ZrWnGe/7wegwofmKro33SoRWUrhgo5lMFgG/dhsvd54w 0zhRyeyDvv2EWoy1lCifuG/0ARCfKHub8ltm2M4Z5w3C9UCXP6GYHiB6fmqLM6ZHmZ35 2RqUjfx1bsDHovynsLnpFrf29YTbEyLuxPP+OcrQU0R2Wj17nllYjh89NpNpDPla8u0L HtoBJcsDiTBBav1ugpfKLVMR2xaEgEk/kQnagGbDFmBcFUfB6QdpXfaJzucsc1bujK8r QjAQuU3X7oF8a1KbAxH9TD3A0n9bSMhqzcqbL74J3ZazzfZjeVQxm8XDRA3CZZAtF9OX rhCw== X-Received: by 10.182.240.228 with SMTP id wd4mr20647679obc.79.1434314431229; Sun, 14 Jun 2015 13:40:31 -0700 (PDT) MIME-Version: 1.0 Received: by 10.76.178.164 with HTTP; Sun, 14 Jun 2015 13:40:10 -0700 (PDT) From: Anton Hughes Date: Sun, 14 Jun 2015 22:40:10 +0200 Message-ID: Subject: Camel Kafka - java.lang.ClassCastException: java.lang.String cannot be cast to [B To: users@camel.apache.org Content-Type: multipart/alternative; boundary=089e01634d6e2b76200518805ac7 --089e01634d6e2b76200518805ac7 Content-Type: text/plain; charset=UTF-8 Hi I'm trying to use the Camel Kafka producer, but am getting the below error. My camel route looks like this: .to("kafka:mykafkabroker:9092??topic=testtopic&serializerClass=kafka.serializer.StringEncoder"); Ive seen others who have the same error, and have resolved this by adding the "serializerClass=kafka.serializer.StringEncoder" parameter, however this has not resolved the issue for me. Anyone have any ideas? Thanks Stacktrace ---------------------------------------------------------------------------------------------------------------------------------------: java.lang.ClassCastException: java.lang.String cannot be cast to [B at kafka.serializer.DefaultEncoder.toBytes(Encoder.scala:34) [kafka_2.10-0.8.1.jar:] at kafka.producer.async.DefaultEventHandler$$anonfun$serialize$1.apply(DefaultEventHandler.scala:128) [kafka_2.10-0.8.1.jar:] at kafka.producer.async.DefaultEventHandler$$anonfun$serialize$1.apply(DefaultEventHandler.scala:125) [kafka_2.10-0.8.1.jar:] at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244) [scala-library-2.10.4.jar:] at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244) [scala-library-2.10.4.jar:] at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33) [scala-library-2.10.4.jar:] at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:34) [scala-library-2.10.4.jar:] at scala.collection.TraversableLike$class.map(TraversableLike.scala:244) [scala-library-2.10.4.jar:] at scala.collection.AbstractTraversable.map(Traversable.scala:105) [scala-library-2.10.4.jar:] at kafka.producer.async.DefaultEventHandler.serialize(DefaultEventHandler.scala:125) [kafka_2.10-0.8.1.jar:] at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:52) [kafka_2.10-0.8.1.jar:] at kafka.producer.Producer.send(Producer.scala:76) [kafka_2.10-0.8.1.jar:] at kafka.javaapi.producer.Producer.send(Producer.scala:33) [kafka_2.10-0.8.1.jar:] at org.apache.camel.component.kafka.KafkaProducer.process(KafkaProducer.java:78) [camel-kafka-2.14.1.jar:2.14.1] at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61) [camel-core-2.14.1.jar:2.14.1] at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:120) [camel-core-2.14.1.jar:2.14.1] at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:72) [camel-core-2.14.1.jar:2.14.1] at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:416) [camel-core-2.14.1.jar:2.14.1] at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) [camel-core-2.14.1.jar:2.14.1] at org.apache.camel.processor.Pipeline.process(Pipeline.java:118) [camel-core-2.14.1.jar:2.14.1] at org.apache.camel.processor.Pipeline.process(Pipeline.java:80) [camel-core-2.14.1.jar:2.14.1] at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:191) [camel-core-2.14.1.jar:2.14.1] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:105) [camel-core-2.14.1.jar:2.14.1] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:87) [camel-core-2.14.1.jar:2.14.1] at org.apache.camel.component.http.CamelServlet.service(CamelServlet.java:144) [camel-http-2.14.1.jar:2.14.1] at javax.servlet.http.HttpServlet.service(HttpServlet.java:847) [jboss-servlet-api_3.0_spec-1.0.0.Final.jar:1.0.0.Final] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:329) [jbossweb-7.0.13.Final.jar:] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:248) [jbossweb-7.0.13.Final.jar:] at org.jboss.weld.servlet.ConversationPropagationFilter.doFilter(ConversationPropagationFilter.java:62) [weld-core-1.1.5.AS71.Final.jar:2012-02-10 15:31] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:280) [jbossweb-7.0.13.Final.jar:] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:248) [jbossweb-7.0.13.Final.jar:] at org.apache.camel.component.swagger.RestSwaggerCorsFilter.doFilter(RestSwaggerCorsFilter.scala:44) [camel-swagger-2.14.1.jar:2.14.1] at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:280) [jbossweb-7.0.13.Final.jar:] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:248) [jbossweb-7.0.13.Final.jar:] at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:275) [jbossweb-7.0.13.Final.jar:] at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:161) [jbossweb-7.0.13.Final.jar:] at org.jboss.as.jpa.interceptor.WebNonTxEmCloserValve.invoke(WebNonTxEmCloserValve.java:50) [jboss-as-jpa-7.1.1.Final.jar:7.1.1.Final] at org.jboss.as.web.security.SecurityContextAssociationValve.invoke(SecurityContextAssociationValve.java:153) [jboss-as-web-7.1.1.Final.jar:7.1.1.Final] at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:155) [jbossweb-7.0.13.Final.jar:] at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:102) [jbossweb-7.0.13.Final.jar:] at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:109) [jbossweb-7.0.13.Final.jar:] at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:368) [jbossweb-7.0.13.Final.jar:] at org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:877) [jbossweb-7.0.13.Final.jar:] at org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.process(Http11Protocol.java:671) [jbossweb-7.0.13.Final.jar:] at org.apache.tomcat.util.net.JIoEndpoint$Worker.run(JIoEndpoint.java:930) [jbossweb-7.0.13.Final.jar:] at java.lang.Thread.run(Thread.java:745) [rt.jar:1.7.0_79] --089e01634d6e2b76200518805ac7--