如何在kafka consumer中使用kafka avro序列化程序编写camel路由器

<dependency>
    <groupId>org.apache.camel</groupId>
    <artifactId>camel-kafka</artifactId>
    <version>x.x.x</version> <!-- 替换为合适的版本号 -->
</dependency>
<dependency>
    <groupId>io.confluent</groupId>
    <artifactId>kafka-avro-serializer</artifactId>
    <version>y.y.y</version> <!-- 替换为合适的版本号 -->
</dependency>

import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.kafka.KafkaConstants;

public class KafkaAvroRouter extends RouteBuilder {
    @Override
    public void configure() throws Exception {
        // 定义Kafka Consumer的配置
        from("kafka:topicName")
            .routeId("kafkaRoute")
            .unmarshal().avro() // 使用Avro反序列化消息
            .process(exchange -> {
                // 在这里进行对消息的处理操作
                String message = exchange.getIn().getBody(String.class);
                // ...
            });
    }
}