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