我有一个apachecamel路由，将avro消息发布到apachekafka主题上。我只在设置producer属性“serializerclass=kafka.serializer.stringencoder”时才能使用它。否则我会
java.lang.classcastexception:java.lang.string不能在kafka.serializer.defaultencoder.tobytes（编码器）处转换为[b]。scala:34)在kafka.producer.async.defaulteventhandler$$anonfun$serialize$1.apply（defaulteventhandler）。scala:130)在kafka.producer.async.defaulteventhandler$$anonfun$serialize$1.apply（defaulteventhandler）。scala:125)在scala.collection.indexedseqoptimized$class.foreach（indexedseqoptimized。scala:33)在scala.collection.mutable.wrappedarray.foreach（wrappedarray。scala:34)在kafka.producer.async.defaulteventhandler.serialize（defaulteventhandler。scala:125)在kafka.producer.async.defaulteventhandler.handle（defaulteventhandler。scala:52)在Kafka。制片人。制片人。发送（制片人。scala:77)在kafka.javaapi.producer.producer.send（producer。scala:33)在org.apache.camel.component.kafka.kafkaproducer.process（kafkaproducer。java:84)
另一方面，我有第二个apache camel路由，应该使用上面的主题，但是失败了
java.io.ioexception:org.apache.avro.io.binarydecover.innerlongdecode（binarydecover）中的长编码无效。java:217)在org.apache.avro.io.binarydecoder.readlong（binarydecoder。java:176)在org.apache.avro.io.resolvingdecoder.readlong（resolvingdecoder。java:162)在org.apache.avro.generic.genericdatumreader.read（genericdatumreader。java:160)在org.apache.avro.generic.genericdatumreader.readfield（genericdatumreader。java:193)在org.apache.avro.generic.genericdatumreader.readrecord（genericdatumreader。java:183)在org.apache.avro.generic.genericdatumreader.read（genericdatumreader。java:151)在org.apache.avro.generic.genericdatumreader.read（genericdatumreader。java:142)在org.apache.camel.dataformat.avro.avrodataformat.unmarshal（avrodataformat。java:133)在org.apache.camel.processor.unmarshalprocessor.process（unmarshalprocessor。java:67)
以下是我使用的apache camel消费代码：

<route id="cassandra.publisher">
            <from
                uri="{{kafka.base.uri}}&amp;topic=sensordata&amp;groupId=Cassandra_ConsumerGroup&amp;consumerId=CassandraConsumer_Instance_1&amp;clientId=adapter2" />      
            <unmarshal>
                <custom ref="avroSensorData" />
            </unmarshal>