我最近注意到Camel现在有自己的Kafka组件所以我决定给它一个旋转.
我决定尝试一个很好的简单文件 - > kafka主题如下......
Test
这看起来很简单,然而,在运行这个我得到...
java.lang.ClassCastException: java.lang.String cannot be cast to [B at kafka.serializer.DefaultEncoder.toBytes(Encoder.scala:34) at org.apache.camel.component.kafka.KafkaProducer.process(KafkaProducer.java:78)
在检查Camel代码时,它执行以下操作......
String msg = exchange.getIn().getBody(String.class); KeyedMessagedata = new KeyedMessage (topic, partitionKey.toString(), msg); producer.send(data);
显然,这是一个序列化问题,我只是不确定是否有解决方法,或者这本身就是现有实现的错误?(或者希望只是我的误解)
有什么建议?谢谢,J