RE: jms to kafka to jms

2016-11-16 Thread Berryman, Eric
The ByteArrayDeserializer at the consumer worked! Thank you! -Original Message- From: Willem Jiang [mailto:willem.ji...@gmail.com] Sent: Tuesday, November 15, 2016 11:46 PM To: users@camel.apache.org Subject: Re: jms to kafka to jms Hi, I'm not sure if it relates t

RE: jms to kafka to jms

2016-11-16 Thread Berryman, Eric
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

Re: jms to kafka to jms

2016-11-16 Thread Tomohisa Igarashi
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/CamelJms

Re: jms to kafka to jms

2016-11-15 Thread Willem Jiang
Hi, I'm not sure if it relates to the deserializerClass option setting of kafka consumer, as you didn't set the option on the kafka endpoint of the second. BTW, You can use the *jmsMessageType* option on the jms endpoint URL to force a specific message type for all messages. Willem Jiang Blog