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.ByteArraySerializer");

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

Reply via email to