Ah! Thank you! This worked.
-----Original Message----- From: Tomohisa Igarashi [mailto:tm.igara...@gmail.com] Sent: Wednesday, November 16, 2016 7:47 AM To: users@camel.apache.org Subject: Re: jms to kafka to jms Hi, I played with this one. So it looks you need to specify ByteArrayDeserializer at kafka consumer side https://github.com/igarashitm/issues/blob/master/camel/misc/src/test/java/CamelJmsKafkaBytesMessageTest.java https://github.com/igarashitm/issues/blob/master/camel/misc/src/test/java/CamelJmsKafkaBytesMessageTest.java#L111-L112 Otherwise StringDeserializer is used anyway. Thanks, Tomo On 11/16/2016 06:07 AM, Berryman, Eric wrote: > Hello! > > I have two routes; one from jms(BytesMessage) to kafka, and one from kafka to > jms(BytesMessage). > When I received my jms object at the end, I noticed it is a TextMessage > instead of BytesMessage. > > from("jms:topic:jmsTopic") > .to("kafka:kafkaserver:9092?topic=jpa-cache" + > "&requestRequiredAcks=-1" > + > "&serializerClass=org.apache.kafka.common.serialization.ByteArraySerializer&" > + > "keySerializerClass=org.apache.kafka.common.serialization.ByteArraySer > ializer"); > > from("kafka:kafkaserver:9092?topic=jpa-cache&groupId=cache&autoOffsetReset=earliest&consumersCount=1") > .to("jms:topic:jmsTopic"); > > Could someone help me preserve the BytesMessage? > > Thank you! > Eric > >
