Spring Cloud Stream -如何在满足条件的情况下读取SpecificRecord，否则读取GenericRecord

spring:
  cloud:
    stream:
      bindings:
        input:
          destination: input-topic
          content-type: application/avro
          consumer:
            use-native-decoding: true
        output:
          destination: output-topic
          content-type: application/avro
          producer:
            use-native-encoding: true

@Configuration
public class MessageConverterConfig {

    @Bean
    public AvroSchemaMessageConverter avroSchemaMessageConverter() {
        return new AvroSchemaMessageConverter();
    }

}

@EnableBinding(Sink.class)
public class MessageListener {

    @StreamListener(Sink.INPUT)
    public void handleMessage(SpecificRecord specificRecord) {
        // 处理SpecificRecord
    }

    @StreamListener(Sink.INPUT)
    public void handleMessage(GenericRecord genericRecord) {
        // 处理GenericRecord
    }

}